articleList

04-Kafka消费者组配置实现点对点消费模型

2025/03/13 posted in  Kafka
Tags: 

编辑消费者配置(确保同个名称group.id一样)
编辑 config/consumer.properties
61788473.png
创建topic, 1个分区

./kafka-topics.sh --create --zookeeper 121.40.146.120:2181 --replication-factor 1 --partitions 2 --topic t1

启动生产者

./kafka-console-producer.sh --broker-list 121.40.146.120:9092  --topic t1

指定配置文件启动 两个消费者

./kafka-console-consumer.sh --bootstrap-server 121.40.146.120:9092 --from-beginning --topic t1 --consumer.config ../config/consumer.properties

现象:只有一个消费者可以消费到数据,一个分区只能被同个消费者组下的某个消费者进行消费