2016-10-27 12 views
0

私は、kafkaのパスをzookeeperに記載するのにzkCli.shを使用します。飼い葉桶でカフカの消費者パスが空ですか?

文書では、consumersパスを除いて、ドキュメント内のすべてのパスがドキュメントに一致することがわかりました。

コマンドls /consumers、応答[]、しかしkafka manager of yahooは、LogSize,Consumer Offsetなどの消費者情報を取得できます。

+0

新しい消費者または古い消費者を使用していますか? – amethystic

+0

@アメジスト、 'org.apache.kafka.clients.consumer.KafkaConsumer'は新しい消費者ですか? –

答えて

3

それはもはや飼い葉桶に依存しない新しい消費者です。 Zkノード '/ consumers'は古い消費者のためのものです。あなたがKafkaManagerの消費者情報を見つけることができる理由は、すでに新しい消費者をサポートしているからです。

カフカには、古い消費者と新しい消費者の両方のステータスを確認するために使用できるコマンドkafka-consumer-groups.shが付属しています。

+0

新しい消費者には、消費者グループとオフセットを得るためのAPIがありますか? –

+0

ConsumerGroupCommand.main(args)を呼び出すことができます。 argsは、 'kafka-consumer-groups.sh'を実行するときに指定するすべてのパラメータを含むスティング型配列です – amethystic

+0

java apiまたはrest api? –

関連する問題