卡夫卡简单的消费者壳

此使用者是一种低级工具,允许你使用来自特定分区,偏移和副本的消息。

有用的参数:

  • 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 开始。