有时需要简单的用shell去检查一个topic下边某一个partition的某个offset的消息。
之前一直用 kafka.tools.ConsoleConsumer, 用的心酸。
后来发现一个稍强大的工具。
https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example
sample usage:
kafka-run-class.sh kafka.tools.SimpleConsumerShell
--broker-list 'xxxx:9092'
--topic 'xxx.xxx.xx.xx'
--max-messages 1
--offset 12345
--partition 1
其他命令:
kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 'xxxx:9092' --topic 'xxxx' --time -1