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客戶端時，有沒有關於如何找出分區領導者的具體示例？