From d7986ad8ddd711a7297bd7de6321b0f92c0be7fb Mon Sep 17 00:00:00 2001
From: EricZeng <zengqiao_cn@163.com>
Date: Sun, 9 Oct 2022 10:38:36 +0800
Subject: [PATCH] =?UTF-8?q?=E6=81=A2=E5=A4=8D=E4=B8=BA=E5=8E=9F=E5=85=88?=
 =?UTF-8?q?=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

恢复为原先代码
---
 .../streaming/km/persistence/kafka/KafkaAdminZKClient.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 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
index 0b824ddb..e6275a60 100644
--- 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,9 +132,9 @@ public class KafkaAdminZKClient extends AbstractClusterLoadedChangedHandler impl
 
             kafkaZkClient = KafkaZkClient.apply(
                     zookeeperAddress,
-//                    false,
+                    false,
 //                    添加支持zk的Kerberos认证
-                    true,
+//                    true,
                     Constant.DEFAULT_SESSION_TIMEOUT_UNIT_MS,
                     Constant.DEFAULT_SESSION_TIMEOUT_UNIT_MS,
                     5,