当前开发环境:CentOS7,kafka_2.12-2.8.0.tgz

1.声明

当前内容主要为学习和测试使用Apache Kafka的基本demo,当前内容主要来源:Apache Kafka官方demo

主要为:

  1. 启动kafka
  2. 使用命令行方式创建topic
  3. 向当前创建的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

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐