1.查看操作生产者命令参数
bin/kafka-console-producer.sh
参数
–bootstrap-server
–topic
2.发送消息
bin/kafka-console-producer.sh --bootstrap-server hadoop102:9092 --topic first
3.消费者命令行操作
bin/kafka-console-consumer.sh
参数
–bootstrap-server
–topic
4.消费消息，再开一个终端
bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --topic first
好像没有收到hello,再发些消息。
查看消费者
这次收到了新发的两个信息，这是因为hello在启动消费者之前发的信息，所以收不到。可以添加一个参数，收到历史信息。
bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --topic first --from-beginning
这样就能收到历史消息
Original: https://www.cnblogs.com/hz-Master/p/16272501.html
Author: hz15968199950
Title: Kafka 生产者、消费者命令行操作
原创文章受到原创版权保护。转载请注明出处：https://www.johngo689.com/563052/
转载文章受原作者版权保护。转载请注明原作者出处！