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

Kafka3.0.0版本——消费者(消费者组原理)

目录

    • 一、消费者组原理
      • 1.1、消费者组概述
      • 1.2、消费者组图解示例
      • 1.3、消费者组注意事项

一、消费者组原理

1.1、消费者组概述

  • Consumer Group(CG):消费者组,由多个consumer组成。形成一个消费者组的条件,是所有消费者的groupid相同。
    注意:
    (1)、消费者组内每个消费者负责消费不同分区的数据,一个分区只能由一个组内消费者消费。
    (2)、消费者组之间互不影响。所有的消费者都属于某个消费者组,即消费者组是逻辑上的一个订阅者。

1.2、消费者组图解示例

  • 示例一
    在这里插入图片描述

  • 示例二
    在这里插入图片描述

  • 示例三
    在这里插入图片描述

1.3、消费者组注意事项

  • 如果向消费组中添加更多的消费者,超过主题分区数量,则有一部分消费者就会闲置,不会接收任何消息。
    在这里插入图片描述
  • 消费者组之间互不影响。所有的消费者都属于某个消费者组,即消费者组是逻辑上的一个订阅者。
    在这里插入图片描述
http://www.lryc.cn/news/159205.html

相关文章:

  • 天津web前端培训班 前端是否适合零基础学?
  • Paimon+StarRocks 湖仓一体数据分析方案
  • 界面控件DevExtreme(v23.2)下半年发展路线图
  • docker镜像配置mysql、redis
  • CentOS7无法连接网络 右上角网络图标消失
  • 为什么创建 Redis 集群时会自动错开主从节点?
  • 分布式 - 服务器Nginx:基础系列之Nginx静态资源配置优化sendfile | tcp_nopush | tcp_nodelay
  • 【动手学深度学习】--语言模型
  • uni-app 之 目录结构
  • 批量上传图片添加水印
  • CPU和GPU性能优化
  • 虚拟机(三)VMware Workstation 桥接模式下无法上网
  • [BFS] 广度优先搜索
  • 蓝桥杯官网填空题(矩形切割)
  • 通过Docker Compose安装MQTT
  • Golang企业面试题
  • Jenkins测试报告样式优化
  • 函数相关概念
  • 2023软考学习营
  • Vue2进阶篇学习笔记
  • Python 正则表达式:强大的文本处理工具
  • Linux如何查看系统时间
  • 46. 出勤率问题
  • Xilinx IDDR与ODDR原语的使用
  • 面试系列 - 序列化和反序列化详解
  • 基于Elasticsearch + Fluentd + Kibana(EFK)搭建日志收集管理系统
  • 【Python小项目之Tkinter应用】解决Python的Pyinstaller将.py文件打包成.exe可执行文件后文件过大的问题
  • Ab3d.DXEngine 6.0 Crack 2023
  • Wireshark抓包常用指令
  • Docker Swarm