Merge pull request #647 from didi/dev

合并DEV分支
2025-12-24 20:22:12 +08:00 · 2022-10-09 16:54:45 +08:00
parent 321125caee 6237b0182f
commit b3e8a4f0f6
7 changed files with 72 additions and 0 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
@@ -133,6 +133,8 @@ public class KafkaAdminZKClient extends AbstractClusterLoadedChangedHandler impl
            kafkaZkClient = KafkaZkClient.apply(
                    zookeeperAddress,
                    false,
+//                    添加支持zk的Kerberos认证
+//                    true,
                    Constant.DEFAULT_SESSION_TIMEOUT_UNIT_MS,
                    Constant.DEFAULT_SESSION_TIMEOUT_UNIT_MS,
                    5,