卡夫卡簡單的消費者殼

此使用者是一種低階工具,允許你使用來自特定分割槽,偏移和副本的訊息。

有用的引數:

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