卡夫卡控制檯消費者

此工具允許你使用主題中的訊息。

要使用舊的消費者實現,請將 --bootstrap-server 替換為 --zookeeper

顯示簡單訊息:

kafka-console-consumer --bootstrap-server localhost:9092 --topic test 

消費舊訊息:

要檢視較舊的訊息,你可以使用 --from-beginning 選項。

顯示鍵值訊息

kafka-console-consumer  --bootstrap-server localhost:9092 --topic test-topic \
    --property print.key=true \
    --property key.separator=,