Apache Kafka:简单的命令行操作topic实现消息发送和接收
当前开发环境:CentOS7,kafka_2.12-2.8.0.tgz1.声明当前内容主要为学习和测试使用Apache Kafka的基本demo,当前内容主要来源:Apache Kafka官方demo主要为:启动kafka使用命令行方式创建topic向当前创建的topic中发布和订阅消息2.基本demo当前的kafka中需要先启动zookeeper,否则直接启动当前的kafka会出现不断的错误启动
·
当前开发环境:CentOS7
,kafka_2.12-2.8.0.tgz
1.声明
当前内容主要为学习和测试使用Apache Kafka的基本demo,当前内容主要来源:Apache Kafka官方demo
主要为:
- 启动kafka
- 使用命令行方式创建topic
- 向当前创建的topic中发布和订阅消息
2.基本demo
当前的kafka中需要先启动zookeeper,否则直接启动当前的kafka会出现不断的错误
启动成功后就可以执行创建topic的命令了
1.创建topic(名称为test-events
的主题)
./bin/kafka-topics.sh --create --topic test-events --bootstrap-server 192.168.1.101:9092
结果:
2.查看创建的topic(主要为--describe
)
./bin/kafka-topics.sh --describe --topic test-events --bootstrap-server 192.168.1.101:9092
3.开始连接这个test-events主题的发布端
./bin/kafka-console-producer.sh --topic test-events --bootstrap-server 192.168.1.101:9092
等待,并按下回车,进入》界面
4.启动消费者并订阅test-events主题的消息
./bin/kafka-console-consumer.sh --topic test-events --from-beginning --bootstrap-server 192.168.1.101:9092
5.开始向该topic上发布消息,以及查看消息
此时消息只要发送那么,这边消息立刻接收
测试成功!基本上就是一个官方的入门demo
更多推荐
已为社区贡献9条内容
所有评论(0)