查看kafka消息的命令行

可以使用kafka自带的命令行工具kafka-console-consumer来查看kafka消息。

命令格式如下：

kafka-console-consumer.sh --bootstrap-server <kafka_broker>:<port> --topic <topic_name> [--from-beginning]

其中，<kafka_broker>是kafka broker的地址，<port>是kafka broker的端口号，<topic_name>是要查看的topic名称。如果加上--from-beginning参数，则可以从最早的消息开始查看。

示例命令：

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test_topic --from-beginning

执行上述命令后，可以实时查看test_topic中的消息。