獲取從卡夫卡消費控制檯腳本

Question

最後的消息，我們可以通過做得到卡夫卡每個消息：

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning 

有沒有辦法讓只有最後一條消息？

編輯：

如果你只是想監控的信息流中的一些形式交往（--max-messages 10），方便的命令是：

watch -n5 "./bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic auction --max-messages 10"

Answer 1

我想用下面的命令行，將工作（即沒有 - 從開始）：

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test 

Answer 2

我得到可能正確的答案從一些谷歌搜索http://grokbase.com/t/kafka/users/145x930s27/how-to-get-last-message

有人建議用getOffsetBefore api找到最後一個偏移量，然後用 使用該偏移量-1來獲取。