2016-08-16 16 views
7

私はこれを行うことができます。Kafkaコンソールコンシューマー:最初からすべてではなく、トピックから最後のN個のメッセージのみを取得する方法は?

./bin/kafka-avro-console-consumer --zookeeper 10.0.0.225:2181/kafka 
--topic myTopic --property schema.registry.url=http://10.0.0.100:8081 
--from-beginning 

しかし、私は、あまりにも多くのメッセージを持っています。むしろ最後のN個のものしか得られないだろう。どのように私はkafkaコンソール消費者でそれを行うことができますか?

+1

ちょうど '--from-beginning'を破棄してしばらくの間それを再実行してから、コンソールコンシューマーを中断するためにCtrl + Cを押してください。結果を一時ファイルにリダイレクトする方がよいでしょう。 – Lhfcws

答えて

3

あなたがバンドルされたバイナリに固執したい場合は、簡単な消費者のシェルを使用する必要があります。

bin/kafka-simple-consumer-shell.sh --broker-list mybroker:9092 --topic 
mytopic --partition mypartition --offset myoffset 

私はktをお勧めします。はるかに速く、軽量で、より良いオプションがあります。

関連する問題