【文件属性】：
文件名称：kafka-broker-discovery:从 Zookeeper 发现 Kafka 经纪人
文件大小：17KB
文件格式：ZIP
更新时间：2021-06-15 10:05:09
Java
kafka-broker-发现
从发现代理。
通常，您通过为集群中的一部分 Kafka 代理提供连接字符串来初始化 Kafka Producer对象； 例如kafka1:2222,kafka2:2222 。 从这里开始，主题、分区和副本信息用于引导与集群的连接。
如果您的应用程序已经连接到 Zookeeper，那么此代码会自动为您发现 Kafka 代理的子集。
用法
String zookeeperHost = " zookeeper1 " ;
String zookeeperPort = " 4444 " ;
KafkaBrokerDiscoverer discoverer = new KafkaBrokerDiscoverer (zookeeperHost, zookeeperPort);
discoverer . getConnectionString();
discover
【文件预览】：
kafka-broker-discovery-master
----.travis.yml(323B)
----pom.xml(2KB)
----LICENCE(1KB)
----src()
--------test()
--------main()
----.gitignore(579B)
----README.md(1KB)