カフカの遅れをすべて確認してください

Question

私は消費者が落ちてもカフカのメッセージを失わないようにしたいと思います。

ログロールが1時間の場合、消費者が1時間以上ダウンした場合、消費されなかったメッセージは失われます。

Kafka 0.10.2.0ですべてのパーティションのすべてのラグを簡単に確認する方法はありますか？

私はうまくいきません。

Answer 1

kafka-consumer-groups.shコマンドを使用すると、遅延を見つけることができます。この例では、私は私にGROUP1が遅れにしていただきました！聞いていることをすべてのトピックを表示

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group group1 

を言って、私の消費者は、最後の数分間ダウンしていました。それは4つの保留中のメッセージを持っていますので、これは私が得るものです。