3.5 消费者组案例

3.5.1 需求

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

3.5.2 操作步骤

步骤1: 添加 group.id 属性

在 hadoop202, hadoop203 设备上, 修改/opt/module/kafka/config/consumer.properties 配置文件中的 group.id 为任意值.

比如: 更改为 atguigu

group.id=atguigu

步骤2: 在 hadoop202 和 hadoop203 设备上分别启动消费者

kafka-console-consumer.sh --topic first --zookeeper hadoop201:2181  --consumer.config config/consumer.properties

说明:

• --consumer.config 来指定 consumer 的配置文件

步骤3: 在 hadoop201 设备生启动生产者, 并生产数据

kafka-console-producer.sh --broker-list hadoop201:9092 --topic first

步骤4:查看 hadoop202 和 hadoop203 的接收

确实同一时刻只有一个消费者收到消息.