使用 kafka 0.7.2 客户端时如何找到分区的领导者/kafka 代理

Question

我正在尝试为 kafka 编写一个 SimpleConsumer，并使用 kafka 客户端 0.7.2 来做同样的事情。我正在遵循 kafka 0.8 文档中给出的示例： https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example

示例使用

private String findNewLeader(String a_oldLeader, String a_topic, int a_partition, int a_port) throws Exception

... 在提供的种子代理列表中查找特定分区的领导者。我们如何在 kafka 0.7.2 中做同样的事情？示例中的某些代码不适用于 0.7.2。

在使用 kafka 0.7.2 客户端时，是否有任何具体示例说明如何确定分区的领导者？

Answer 1

根据我在 0.7.2 中的理解，您不需要为主题/分区找到领导代理。相反，您需要连接到每个代理并向所有代理请求特定分区的消息。