大数据技术之kafka (第 3 章 Kafka 架构深入 ) 消费者组案例

水深无声 2023-07-22 15:27 32阅读 0赞

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）

![20200406141850504.png][]

（3）在 backup03 上启动生产者

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

这里我直接在backup01启动生产者，发送了两条数据  （启动backup03也是一样的）

![20200406142517943.png][]

其中一个消费者（消费了hello）：

![20200406142718981.png][]

另一个消费者（消费了atguigu）

![20200406142629689.png][]

（4）查看 backup01 和 backup02 的接收者。 （上面已经查看过了）  
  证实： 同一时刻只有一个消费者接收到消息。

下面这里启动backup03生成者

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3l3bDQ3MDgxMjA4Nw_size_16_color_FFFFFF_t_70][] 消费了hello world

![20200406143322824.png][] 消费了yuwenlong how are you![20200406143350781.png][]

再次证明了  同一时刻只有一个消费者接收到消息

[20200406141850504.png]: /images/20230528/c6857e4aa28846dc8eb9cab8ccecbb13.png
[20200406142517943.png]: /images/20230528/f7d5193deab04aac8304f03ffc669651.png
[20200406142718981.png]: /images/20230528/66076c2ec59343939da4ef97c8662342.png
[20200406142629689.png]: /images/20230528/5f280b9ecfdd4d77912c8d01cc712c5f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3l3bDQ3MDgxMjA4Nw_size_16_color_FFFFFF_t_70]: /images/20230528/8da2e25fd173410295e86bdbaeae1074.png
[20200406143322824.png]: https://img-blog.csdnimg.cn/20200406143322824.png
[20200406143350781.png]: /images/20230528/505d16a9f4dc44998873fa2924ca094f.png