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)