gpt4 book ai didi

broker - 在kafka 0.8 producer中,不指定broker.list就不能指定zk.connect

转载 作者:行者123 更新时间:2023-12-04 05:16:35 26 4
gpt4 key购买 nike

我发现在 Kafka 0.72 中,我们可以指定 zk.connect 或 broker.list。但是在Kafka 0.8中,我们只能指定broker.list,不指定broker.list就不能指定zk.connect。我想,在这种情况下,我们不能通过zookeeper来平衡producer。如果有人使用Kafka 0.8,或者对此有一些了解?非常感谢!

最佳答案

您仍然可以使用 ZooKeeper 客户端来检索代理列表:

ZkClient zkClient = new ZkClient("localhost:2108", 4000, 6000, new BytesPushThroughSerializer());
List<String> brokerList = zkClient.getChildren("/brokers/ips");

据此,您不必在客户端对代理列表进行“硬编码”,并且就系统架构而言,您是灵活的。但无论如何,这会再次添加 ZooKeeper 依赖项,这实际上在多种环境中对生产者来说是不利的。

如果您想详细了解所谓的“集群元数据 API”解决方案,请查看此链接: https://issues.apache.org/jira/browse/KAFKA-369

最好的

关于broker - 在kafka 0.8 producer中,不指定broker.list就不能指定zk.connect,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/14190263/

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com