恢复为原先代码

恢复为原先代码

恢复为原先代码
22469835 · EricZeng · GitHub · d1597463 · 22469835
隐藏空白更改
内联并排

Showing with 2 addition and 2 deletion

km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaAdminZKClient.java ...ow/streaming/km/persistence/kafka/KafkaAdminZKClient.java +2 -2

未找到文件。
--- 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,