kafka-consumer-groups.shと同等ですか？

Question

私は0.10.2バージョンを使用しています。私はこのすべては、CLIを使用せずに自分のアプリケーション内の情報を相殺表示したいので

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

を：私は、任意のカフカのJava APIを使用してのようなオフセット情報を取得することができない知っていただきたいと思います。

Answer 1

Javaクライアントに相当するとは思われません。私はそのスクリプトを見て、scalaクラスConsumerGroupCommandを呼び出します。

私はscalaに精通していませんが、そのクラスがコマンドを実装する内部クラス（e、g、ZkConsumerGroupService）を公開していないように見えるので、ユーザーアプリケーションから呼び出せないように見えます。

結果を含むオブジェクトを生成するのではなく、とにかくstdoutに直接書き込むように見えます。

私はあなたがそのようなクラスからのコードの束を持ち上げる必要があるだろう

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

それとも、...あなたはそれを実行し、標準出力をキャプチャする可能性があるとします。