卡夫卡简单的消费者壳
此使用者是一种低级工具,允许你使用来自特定分区,偏移和副本的消息。
有用的参数:
parition
:要使用的特定分区(默认为全部)offset
:开始偏移。使用-2
从头开始使用消息,-1
从末尾开始消费。max-messages
:要打印的消息数replica
:副本,默认为经纪人领导者(-1)
例:
kafka-simple-consumer-shell \
--broker-list localhost:9092 \
--partition 1 \
--offset 4 \
--max-messages 3 \
--topic test-topic
显示来自分区 1 的 3 条消息,从主题 test-topic 的偏移量 4 开始。