标签：bin console 生产者 bootstrap kafka topic -- 命令行 Kafka

1.查看操作生产者命令参数

bin/kafka-console-producer.sh

参数 --bootstrap-server <String: server toconnect to> ，连接的 Kafka Broker 主机名称和端口号。 --topic <String: topic>，操作的 topic 名称。 2.发送消息

bin/kafka-console-producer.sh --bootstrap-server hadoop102:9092 --topic first

3.消费者命令行操作

bin/kafka-console-consumer.sh

参数 --bootstrap-server <String: server toconnect to> ，连接的 Kafka Broker 主机名称和端口号。 --topic <String: topic>，操作的 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 

这样就能收到历史消息

标签：bin,console,生产者,bootstrap,kafka,topic,--,命令行,Kafka
来源： https://www.cnblogs.com/hz-Master/p/16272501.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。