kafka-consumer-groups.sh相當於？

Question

我正在使用0.10.2版本。我想知道是否有任何卡夫卡的Java API可以獲取偏移信息如使用：

./bin/kafka-consumer-groups.sh --bootstrap-server 192.168.0.28:9092 --describe --group test 

因爲我想告訴所有這一切偏移信息在我的應用程序，而無需使用CLI。

Answer 1

我不認爲在Java客戶端中有相應的東西;我只是看着那個腳本，它調用了一個scala類ConsumerGroupCommand。

我不熟悉的斯卡拉，但它看起來像類不公開的內部類（E，G，ZkConsumerGroupService）實現了命令所以它看起來並不像它可以從用戶的應用程序調用。

看起來它直接寫入標準輸出，而不是產生一個結果的對象。

我想你可以運行它，並捕獲標準輸出...

ConsumerGroupCommand.main(new String[] {"--bootstrap-server", "localhost:9092", 
      "--describe", 
      "--group", "test"}); 

或者，你必須從該類提起一串代碼。