2

我是 Kafka 的新手,我正在探索通过 ZooKeeper 动态发现给定主题的代理的选项,而不是使用静态代理列表。这就是我想要做的,1. 对于给定的主题,获取分区列表。2. 对于每个分区,获取可以读取消息的领导代理列表。3. 使用简单消费者从每个代理读取主题的可用消息。

首先这是正确的方法吗?只从分区的领导者那里读取是否有意义?如果是这样,是否有任何代码示例?

4

0 回答 0