卡夫卡簡單的消費者殼
此使用者是一種低階工具,允許你使用來自特定分割槽,偏移和副本的訊息。
有用的引數:
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 開始。