卡夫卡控制台消费者
此工具允许你使用主题中的消息。
要使用旧的消费者实现,请将
--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=,