文件名称：kafka-broker-discovery:从 Zookeeper 发现 Kafka 经纪人
文件大小：17KB
文件格式：ZIP
更新时间：2024-07-05 03:51:49
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)