博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
KAFKA详解:分区说明(三)
阅读量:5084 次
发布时间:2019-06-13

本文共 499 字,大约阅读时间需要 1 分钟。

一、分区

1、文字说明

是针对于某一个主题下数据的拆分

让消费者在拿数据的时候,速度会更快

一个broker服务下可以有多个分区

某一个分区中数据是有序的,且不可修改。但不同的分区数据是无序的

新进来的消息,会追加到某一个分区的尾部

2、图形展示

 

二、分区与消费组之间的关系?

1、文字说明

消费组:由一个或者多个消费者组成,同一个组中的消费者对于同一条消息只消费一次

某一个主题下的分区数,对于消费组来说,应该小于等于改主题下的分区数

如:某一个主题有4个分区,那么消费组中的消费者应该小于4,而且最好与分区成整倍(1 2 4)

同一个分区下的数据,在同一时刻,不能同一个消费组的不同消费者消费

2、图形说明

 

三、分区中的数据有相应的编号【offset--偏移量】

1、文字说明

偏移量:记录当前有多少记录数、而且让消费者可以知道自己消费到说明地方

可以让消费者自定义选择消费某一条消息【对于同一条消息,消费者可以消费多次】
确定一条唯一的数据:主题+分区+偏移量

2、图形说明

 

转载于:https://www.cnblogs.com/luoahong/articles/9712377.html

你可能感兴趣的文章
Enterprise Library - Data Access Application Block 6.0.1304
查看>>
重构代码 —— 函数即变量(Replace temp with Query)
查看>>
Bootstrap栅格学习
查看>>
程序员的数学
查看>>
聚合与组合
查看>>
jQuery如何获得select选中的值?input单选radio选中的值
查看>>
设计模式 之 享元模式
查看>>
如何理解汉诺塔
查看>>
洛谷 P2089 烤鸡【DFS递归/10重枚举】
查看>>
15 FFT及其框图实现
查看>>
Linux基本操作
查看>>
osg ifc ifccolumn
查看>>
C++ STL partial_sort
查看>>
3.0.35 platform 设备资源和数据
查看>>
centos redis 安装过程,解决办法
查看>>
IOS小技巧整理
查看>>
WebDriverExtensionsByC#
查看>>
我眼中的技术地图
查看>>
lc 145. Binary Tree Postorder Traversal
查看>>
sublime 配置java运行环境
查看>>