1）需求：測試同一個消費者組中的消費者，同一時刻只能有一個消費者消費。?
2）案例實操?
?（1）在?backupo01、backupo02?上修改/usr/local/hadoop/kafka/kafka_2.12-2.4.1/config/consumer.properties 配置
文件中的 group.id 屬性為任意組名。?

[root@backup01 config]$ vim consumer.properties group.id=yuwenlong

（2）在 backup01、backup02?上分別啟動消費者

[root@backup01?kafka_2.12-2.4.1]$ bin/kafka-console-consumer.sh --bootstrap-server backup01:9092 --topic bigdata --consumer.config config/consumer.properties [root@backup02 kafka_2.12-2.4.1]# bin/kafka-console-consumer.sh --bootstrap-server backup01:9092 --topic bigdata --consumer.config config/consumer.properties

查看下消費者組（已經有一個消費者組yuwenlong）

（3）在 backup03 上啟動生產者

[root@backup03?kafka_2.12-2.4.1]$ bin/kafka-console-producer.sh --broker-list backup03:9092 --topic bigdata

這里我直接在backup01啟動生產者，發送了兩條數據??（啟動backup03也是一樣的）

其中一個消費者（消費了hello）：

另一個消費者（消費了atguigu）

（4）查看 backup01?和 backup02?的接收者。 （上面已經查看過了）
? 證實： 同一時刻只有一個消費者接收到消息。?

下面這里啟動backup03生成者

?消費了hello world

?消費了yuwenlong how are you

再次證明了? 同一時刻只有一個消費者接收到消息

總結

以上是生活随笔為你收集整理的大数据技术之kafka (第 3 章 Kafka 架构深入 ) 消费者组案例的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。