Apache Kafka：简单的命令行操作topic实现消息发送和接收

Posted 2021-07-24 你是小KS

当前开发环境：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