05-Kafka消费者组配置实现发布订阅消费模型

• 编辑消费者配置（确保group.id 不一样）

  • 编辑 config/consumer-1.properties
  • 编辑 config/consumer-2.properties

• 创建topic, 2个分区

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

• 启动生产者

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

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

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

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

• 现象
  • 两个不同消费者组的节点，都可以消费到消息，实现发布订阅模型