10、kafka 实战 - kafka消费者组案例

消费者组案例

需求：测试同一个消费者组中的消费者，同一时刻只能有一个消费者消费。

修改consumer.properties的group.id为任意的一个组名：

vim consumer.properties

启动两个消费者，用同一个kafka服务开两个终端窗口执行即可：

bin/kafka-console-consumer.sh --zookeeper hll4:2181 --topic bigdata --consumer.config config/consumer.properties

或者在另外一台kafka服务器开启一个消费者，前提是需要修改这台kafka的consumer.properties的group.id组名保持一样

启动一个生产者发送消息，会看到发完一个消息后只有一个消费者消费了消息

查看消费者：

同组中同一时刻只有一个消费者消费数据，不同组中可以同时消费，前提是订阅的是同一个主题