私は、kafka
のパスをzookeeper
に記載するのにzkCli.sh
を使用します。飼い葉桶でカフカの消費者パスが空ですか?
文書では、consumers
パスを除いて、ドキュメント内のすべてのパスがドキュメントに一致することがわかりました。
コマンドls /consumers
、応答[]
、しかしkafka manager of yahooは、LogSize
,Consumer Offset
などの消費者情報を取得できます。
私は、kafka
のパスをzookeeper
に記載するのにzkCli.sh
を使用します。飼い葉桶でカフカの消費者パスが空ですか?
文書では、consumers
パスを除いて、ドキュメント内のすべてのパスがドキュメントに一致することがわかりました。
コマンドls /consumers
、応答[]
、しかしkafka manager of yahooは、LogSize
,Consumer Offset
などの消費者情報を取得できます。
それはもはや飼い葉桶に依存しない新しい消費者です。 Zkノード '/ consumers'は古い消費者のためのものです。あなたがKafkaManagerの消費者情報を見つけることができる理由は、すでに新しい消費者をサポートしているからです。
カフカには、古い消費者と新しい消費者の両方のステータスを確認するために使用できるコマンドkafka-consumer-groups.shが付属しています。
新しい消費者には、消費者グループとオフセットを得るためのAPIがありますか? –
ConsumerGroupCommand.main(args)を呼び出すことができます。 argsは、 'kafka-consumer-groups.sh'を実行するときに指定するすべてのパラメータを含むスティング型配列です – amethystic
java apiまたはrest api? –
新しい消費者または古い消費者を使用していますか? – amethystic
@アメジスト、 'org.apache.kafka.clients.consumer.KafkaConsumer'は新しい消費者ですか? –