当前位置: 首页 > ds >正文

kafka 中消费者 groupId 是什么

📚 什么是 groupId?

groupId 是 Kafka 里消费者组(Consumer Group)的唯一标识

  • 同一个 groupId 的消费者一起共享消费一条消息只给组内一个消费者处理
  • 不同 groupId 的消费者组各自独立消费,互不干扰。

✨ 举个例子(超级通俗版)

假设 Kafka 主题 test-topic 里有 100条消息。

有两种情况:

1. 同一个 groupId

消费者实例

消费者A

group-1

消费者B

group-1

👉 A 和 B 是一组人
👉 Kafka 会把这100条消息分给他们,比如 A 处理50条,B处理50条。
👉 一条消息只会被一个人消费。


2. 不同 groupId

消费者实例

消费者A

group-1

消费者B

group-2

👉 A 和 B 是两组人
👉 Kafka 会把全部100条消息都推给A,又全部推给B
👉 每组都会收到完整的100条消息。


🚀 总结

名称

意义

groupId

定义一组消费者的 "身份"

同组

消息平分消费

不同组

每组都全量消费


📦 那么在你的项目里,groupId用来干嘛?

比如你写了一个批量消费者监听器:

@KafkaListener(topics = "test-topic", groupId = "your-consumer-group")
public void listen(List<String> messages) {System.out.println("Received batch: " + messages);
}

这里的 groupId = your-consumer-group

  • 告诉Kafka:这些消费者属于同一个组
  • Kafka自动分配消息给组里的消费者
  • 一条消息只被这个组里一个人消费一次

❗ 注意

  • 如果 groupId 写错了,可能导致同一条消息消费多次(因为是不同组)。
  • 如果不写 groupId,Spring Kafka 会随机给你一个,导致每次都重新消费。
http://www.xdnf.cn/news/2454.html

相关文章:

  • Word处理控件Spire.Doc系列教程:C# 通过模板创建 Word 文档
  • 【Java】IntelliJ IDEA 社区版安装
  • MAVLink协议:原理、应用与实践
  • 4.26 数据交互升级引入配置文件
  • Python 第 12、13 节课 - 元组和列表
  • C语言 函数递归
  • TP4056 电池管理芯片介绍及电路应用
  • 计算机二级MS Office第八套演示文稿
  • Pygame入门:零基础打造你的第一个游戏窗口
  • [C++] 高精度乘法
  • 八猴渲染器三维场景实时预览软件 Marmoset Toolbag 5.01 安装包免费下载
  • 九、内联函数(Inline Functions)
  • 《Keras 3部署全攻略:从新手到实战高手》
  • 网络流之最大流(Dinic)
  • Springboot基础篇
  • 牛客:链表内指定区间反转
  • 在 Ubuntu24.04 LTS 上 Docker 部署英文版 n8n 和 部署中文版 n8n-i18n-chinese
  • 前端自定义文本生成文件下载
  • 第八章 IO流
  • 树状数组详解
  • ZBrush2025建模软件下载 ZBrush中文版免费下载 ZBrush版本大全
  • 数据预处理中比较重要的知识点
  • 【白雪讲堂】
  • CPU与GPU的功能与区别解析
  • 【LCMM】纵向轨迹模型,组轨迹模型
  • c++学习小结
  • AUTOSAR图解==>AUTOSAR_SWS_StandardTypes
  • PotPlayer,强大的高清视频播放器
  • 使用 Spring Boot 进行开发
  • TypeScript基础数据类型详解