0
我想为kafka编写一个SimpleConsumer并使用kafka客户端0.7.2来做同样的事情。我下面的卡夫卡0.8文档中给出的示例： https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example如何在使用kafka时遇到分区的leader/kafka经纪人0.7.2客户端
的例子使用
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客户端时，有没有关于如何找出分区领导者的具体示例？