私は完全にKafka土地にしゃがんでいます コマンドを実行すると
/cfintools/confluent-4.0.0/bin/kafka-avro-console-consumer --topic $t --bootstrap-server $bt --consumer.config /cfintools/avro_consumer_ssl_cfin_prod.properties --property schema.registry.url=$regd --from-beginning
物事が戻るには永遠にかかります。エラーはありませんが、データもありません。
私が欲しいのは、そのトピックの最新の 10 件のメッセージと、 と について読んだことだけpartitionですoffsets。今、私はこの情報を取得するためにどのようにすればよいかわかりませんこのコマンドについて読んだ他の場所
./bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group count_errors --describe
しかし、私は自分の消費者グループを知りません。topic最初のコマンドで言及されている名前とその他のパラメーターを知っているだけなので、この ltd 情報を使用して、特定のパーティションとオフセットのみを検索するか、その他の方法でトピックの最後の 10 個の奇妙なメッセージを取得する方法を教えてください。
ktツールを使ってみた
$ ./kt topic -brokers $bk -filter $t -partitions -leaders -replicas
failed to create client err=kafka: client has run out of available brokers to talk to (Is your cluster reachable?)
私はそれらを使用しているので、ブローカーが有効であることを知っています
私が最も親切にしたいこと：
partition消費者グループなどの追加情報なしで、最も簡単な方法で取得およびオフセットします- 最後の 10 個を自動的に検索する他のアプローチ
messages- そのパーティションとオフセットとフェッチ - 私が怒るのを防いでくれるGUIベースのツール