[KAFKA-15156] Update cipherInformation correctly in DefaultChannelMetadataRegistry

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 3.9.0
• Labels: newbie
• Assignee: Ganesh Sadanala
• Reporter: Divij Vaidya
• Created: 06/Jul/23 10:45
• Updated: 03/Jun/24 22:16
• Resolved: 03/Jun/24 16:33

Description

At https://github.com/apache/kafka/blob/4a61b48d3dca81e28b57f10af6052f36c50a05e3/clients/src/main/java/org/apache/kafka/common/network/DefaultChannelMetadataRegistry.java#L25 

we do not end up assigning the new value of cipherInformation to the member variable. 

The code over here, should be the following so that we can update the cipher information.

if (cipherInformation == null) {     
    throw Illegal exception.
}
this.cipherInformation = cipherInformation

 

 
While this class is only used in tests, we should still fix this. It's a minor bug.

Issue Links

• links to: GitHub Pull Request #13966
• links to: GitHub Pull Request #16169