卡夫卡控制台消费者

此工具允许你使用主题中的消息。

要使用旧的消费者实现,请将 --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=,