You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ch...@apache.org on 2024/06/03 16:32:54 UTC
(kafka) branch trunk updated: KAFKA-15156 Update cipherInformation correctly in DefaultChannelMetadataRegistry (#16169)
This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 04e6ef47508 KAFKA-15156 Update cipherInformation correctly in DefaultChannelMetadataRegistry (#16169)
04e6ef47508 is described below
commit 04e6ef4750806f6a787363b7d005da47fd36db98
Author: GANESH SADANALA <40...@users.noreply.github.com>
AuthorDate: Mon Jun 3 12:32:47 2024 -0400
KAFKA-15156 Update cipherInformation correctly in DefaultChannelMetadataRegistry (#16169)
Reviewers: Chia-Ping Tsai <ch...@gmail.com>
---
.../apache/kafka/common/network/DefaultChannelMetadataRegistry.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git a/clients/src/main/java/org/apache/kafka/common/network/DefaultChannelMetadataRegistry.java b/clients/src/test/java/org/apache/kafka/common/network/DefaultChannelMetadataRegistry.java
similarity index 93%
rename from clients/src/main/java/org/apache/kafka/common/network/DefaultChannelMetadataRegistry.java
rename to clients/src/test/java/org/apache/kafka/common/network/DefaultChannelMetadataRegistry.java
index ae9e9a83a0c..8985d00410c 100644
--- a/clients/src/main/java/org/apache/kafka/common/network/DefaultChannelMetadataRegistry.java
+++ b/clients/src/test/java/org/apache/kafka/common/network/DefaultChannelMetadataRegistry.java
@@ -22,9 +22,7 @@ public class DefaultChannelMetadataRegistry implements ChannelMetadataRegistry {
@Override
public void registerCipherInformation(final CipherInformation cipherInformation) {
- if (this.cipherInformation != null) {
- this.cipherInformation = cipherInformation;
- }
+ this.cipherInformation = cipherInformation;
}
@Override