1）需求：測(cè)試同一個(gè)消費(fèi)者組中的消費(fèi)者，同一時(shí)刻只能有一個(gè)消費(fèi)者消費(fèi)。?
2）案例實(shí)操?
?（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?上分別啟動(dòng)消費(fèi)者

[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

查看下消費(fèi)者組（已經(jīng)有一個(gè)消費(fèi)者組yuwenlong）

（3）在 backup03 上啟動(dòng)生產(chǎn)者

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

這里我直接在backup01啟動(dòng)生產(chǎn)者，發(fā)送了兩條數(shù)據(jù)??（啟動(dòng)backup03也是一樣的）

其中一個(gè)消費(fèi)者（消費(fèi)了hello）：

另一個(gè)消費(fèi)者（消費(fèi)了atguigu）

（4）查看 backup01?和 backup02?的接收者。 （上面已經(jīng)查看過(guò)了）
? 證實(shí)： 同一時(shí)刻只有一個(gè)消費(fèi)者接收到消息。?

下面這里啟動(dòng)backup03生成者

?消費(fèi)了hello world

?消費(fèi)了yuwenlong how are you

再次證明了? 同一時(shí)刻只有一個(gè)消費(fèi)者接收到消息

總結(jié)

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

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。