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

一、Kafka概述

目录

    • 1.3 Kafka的基础架构

1.3 Kafka的基础架构

在这里插入图片描述

  • Producer:消息生产者,就是向 Kafka broker 发消息的客户端
  • Consumer:消息消费者,向 Kafka broker 取消息的客户端。
  • Consumer Group(CG):消费者组,由多个 consumer 组成。消费者组内每个消费者负责消费不同分区的数据,一个分区只能由一个组内消费者消费;消费者组之间互不影响。所有的消费者都属于某个消费者组,即消费者组是逻辑上的一个订阅者。
  • Broker:一台 Kafka 服务器就是一个 broker。一个集群由多个 broker 组成。一个broker 可以容纳多个 topic。
  • Topic:可以理解为一个队列,生产者和消费者面向的都是一个 topic。
  • Partition:为了实现扩展性,一个非常大的 topic 可以分布到多个 broker(即服务器)上,一个 topic 可以分为多个 partition,每个 partition 是一个有序的队列
  • Replica:副本。一个 topic 的每个分区都有若干个副本,一个 Leader 和若干个Follower。
  • Leader:每个分区多个副本的“主”,生产者发送数据的对象,以及消费者消费数据的对象都是 Leader。
  • Follower:每个分区多个副本中的“从”,实时从 Leader 中同步数据,保持和Leader 数据的同步。Leader 发生故障时,某个 Follower 会成为新的 Leader。
http://www.lryc.cn/news/135913.html

相关文章:

  • 【数据结构OJ题】合并两个有序链表
  • C++ LibCurl 库的使用方法
  • 自然语言处理从入门到应用——LangChain:索引(Indexes)-[向量存储器(Vectorstores)]
  • 【C++练习】普通方法+利用this 设置一个矩形类(Rectangle), 包含私有成员长(length)、 宽(width), 定义一下成员函数
  • 电子电路学习笔记之SA1117BH-1.2TR——LDO低压差线性稳压器
  • 【LeetCode-面试经典150题-day7】
  • 00-音视频-概述
  • SOFARPC(笔记)
  • 无线上网连接及配置
  • Webpack减少打包数量和体积(Umi 3.*中)
  • python Crypto 包安装
  • 时序预测 | MATLAB实现SO-CNN-LSTM蛇群算法优化卷积长短期记忆神经网络时间序列预测
  • 前端开发,怎么解决浏览器兼容性问题? - 易智编译EaseEditing
  • 树莓派3B安装64位操作系统
  • Mysql系列 - 第2天:详解mysql数据类型(重点)
  • Linux常用的运维命令
  • 【从零学习python 】50.面向对象编程中的多态应用
  • 实现Token刷新机制
  • FlaUi输入账号密码
  • ModStartBlog v8.0.0 博客归档页面,部分组件升级
  • 使用 PyTorch 进行高效图像分割:第 4 部分
  • 西班牙卡瓦起泡酒的风味搭配
  • Java项目-苍穹外卖-Day05
  • 取模运算符在数组下标的应用
  • Firefox(火狐),使用技巧汇总,问题处理
  • 耐腐蚀高速数控针阀和多功能PID控制器在流量比率控制中的应用
  • C语言:选择+编程(每日一练Day6)
  • 微信小程序教学系列(8)
  • 情人节定制:HTML5 Canvas全屏七夕爱心表白特效
  • 操作系统-笔记-第五章-输入输出管理