これを行う方法が必要であることは知っていますが、これを理解することはできません。キューからすべてのメッセージを読み取ったら、kafka コンシューマーを停止する必要があります。
誰かがこれに関する情報を提供できますか?
質問する
14392 次
4 に答える
1
Scala クライアントを使用することに固執していない場合は、パーティションの終わりに達したときに終了するように指示するオプションを指定してkafkacatを試してください。-e
たとえば、mytopic パーティション 2 からのすべてのメッセージを消費してから終了するには:
$ kafkacat -b mybroker -t mytopic -p 2 -o beginning -e
または、最後の 3000 件のメッセージを消費してから終了します。
$ kafkacat -b mybroker -t mytopic -p 2 -o -3000 -e
于 2014-12-18T21:36:58.780 に答える