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