Divij Vaidya created KAFKA-15156: ------------------------------------ Summary: Update cipherInformation correctly in DefaultChannelMetadataRegistry Key: KAFKA-15156 URL: https://issues.apache.org/jira/browse/KAFKA-15156 Project: Kafka Issue Type: Bug Reporter: Divij Vaidya
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. {noformat} if (cipherInformation == null) { throw Illegal exception. } this.cipherInformation = cipherInformation{noformat} While this class is only used in tests, we should still fix this. It's a minor bug. -- This message was sent by Atlassian Jira (v8.20.10#820010)