修改代码支持ZK-Kerberos认证

2025-12-24 11:52:08 +08:00 · 2022-09-21 15:54:30 +08:00
parent 045f65204b
commit b4580277a9
1 changed files with 3 additions and 1 deletions
--- a/km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaAdminZKClient.java
+++ b/km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaAdminZKClient.java
@@ -132,7 +132,9 @@ public class KafkaAdminZKClient extends AbstractClusterLoadedChangedHandler impl

            kafkaZkClient = KafkaZkClient.apply(
                    zookeeperAddress,
-                    false,
+//                    false,
+//                    添加支持zk的Kerberos认证
+                    true,
                    Constant.DEFAULT_SESSION_TIMEOUT_UNIT_MS,
                    Constant.DEFAULT_SESSION_TIMEOUT_UNIT_MS,
                    5,