卡夫卡控制檯消費者
此工具允許你使用主題中的訊息。
要使用舊的消費者實現,請將
--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=,