一、搭建环境
- 沿用之前部署的三分区两副本的topic
- 创建生产者
切入bin目录下
./kafka-console-producer --broker-list localhost:9092 --topic test
- 创建消费者
切入bin目录下
./kafka-console-consumer --bootstrap-server localhost:9092 --topic test
生产者消费者具体参数参考版本号
具体实现截图
依照顺序让producer生产三个消息
image.png
此时切入消费者
可以看到consumer收到了producer生产的三个消息
image.png
发布订阅实现成功
二、要点
1. 点对点
2. 发布订阅
3. 分区与消息顺序
- 同一个组的分区只能消费一个生产者发送的消息，一个生产者可以发送给不同组的分区消息
// TODO: 2023/1/10
