8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2025-12-24 11:52:08 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

修改代码支持ZK-Kerberos认证

Browse Source
This commit is contained in:
luhe
2022-09-21 15:54:30 +08:00
parent f234f740ca
commit 8d2fbce11e
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaAdminZKClient.java
View File

@@ -132,7 +132,9 @@ public class KafkaAdminZKClient extends AbstractClusterLoadedChangedHandler impl
kafkaZkClient = KafkaZkClient.apply( kafkaZkClient = KafkaZkClient.apply(
zookeeperAddress, zookeeperAddress,
false, // false,
// 添加支持zk的Kerberos认证
true,
Constant.DEFAULT_SESSION_TIMEOUT_UNIT_MS, Constant.DEFAULT_SESSION_TIMEOUT_UNIT_MS,
Constant.DEFAULT_SESSION_TIMEOUT_UNIT_MS, Constant.DEFAULT_SESSION_TIMEOUT_UNIT_MS,
5, 5,