前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Kafka集群( 2.8.0版本)之三:消费者组

Kafka集群( 2.8.0版本)之三:消费者组

作者头像
程裕强
发布2021-09-09 15:52:10
2690
发布2021-09-09 15:52:10
举报

1、启动两个消费者,属于同一个消费者组test

代码语言:javascript
复制
[root@node2 kafka-2.8.0]#  bin/kafka-console-consumer.sh --topic demo --bootstrap-server node1:9092 --group test
代码语言:javascript
复制
[root@node3 kafka-2.8.0]# bin/kafka-console-consumer.sh --topic demo --bootstrap-server node1:9092 --group test
代码语言:javascript
复制
[root@node3 kafka-2.8.0]# bin/kafka-consumer-groups.sh -bootstrap-server node1:9092 --list
test
[root@node3 kafka-2.8.0]# 

2、生产者连续发送消息

代码语言:javascript
复制
[root@node1 kafka-2.8.0]# bin/kafka-console-producer.sh --topic demo --bootstrap-server node1:9092
>m1
>m2
>m3
>m4
>m5
>m6
>m7
>m8
>m9
>m10
>

3、查看两个同组消费者的消费情况

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

4、小结

  • 多个消费者可以组成一个消费者组
  • 同组消费者共同消费消息,某一个topic的同一消息只能被同组的一个消费者消费
本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2021-09-06 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 1、启动两个消费者,属于同一个消费者组test
  • 2、生产者连续发送消息
  • 3、查看两个同组消费者的消费情况
  • 4、小结
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档