你的浏览器禁用了JavaScript, 请开启后刷新浏览器获得更好的体验!
发现
分享
文章
活动
登录
ELK,萌萌哒
kafka新增分区对单分区时序性影响
默认分类
| 作者
walter123
| 发布于2019年06月25日 | 阅读数:
3359
分享到:
QQ空间
新浪微博
微信
QQ好友
印象笔记
有道云笔记
请教大佬们一个问题,用kafka如何保证以后新增分区的时候,相同key的消息消费还是有序的(不新增分区的话单partition是有序的)
没有找到相关结果
已邀请:
与内容相关的链接
提交
2 个回复
HelloClyde
赞同来自:
rochy
推kafka指定key,就会按照key hash,分配到partition,同一key肯定到同一partition,不就是有序的吗
Bobbao
赞同来自:
kafka中同一个partition中的消息都是有序的,你只用指定key为分片键,这样所有key相同的消息都会放到同一个partition中
要回复问题请先
登录
或
注册
发起人
walter123
IT
活动推荐
Aug
15
2025 Zabbix 中国峰会
上海
·
8-15 周五
·
报名中
Oct
17
第27届 GOPS 全球运维大会暨研运数智化技术峰会 · 上海站
上海
·
10-17 周五
·
报名中
相关问题
新增节点数据均衡.
大家可以讲讲使用ELK架构吗?我打算大家kafka+rsyslog+logstash+elasticsearch+kibana,这个架构可行吗
Filebeat与kafka集成
Logstash吞吐量求解(从Kafka消费永远赶不上生产速度)
logstash 消费kafka数据时,partition持续rebalancing
filebeat链接kafka,kafka死掉会出现数据丢失吗?
请问一下:logstash 消费kafka的消息,如何解决反序列化问题。能够引入jar 包序列化类么?
filebeat和ELK全用了6.2.4了,kafka是1.1.0,filebeat写入kafka后,所有信息都保存在message字段中,怎么才能把message里面的字段都单独分离出来呢?
logstash收取的kafka消息如何去提取
filebeat->kafka没反应。
logstash消费kafka的问题
问题状态
最新活动:
2019-06-26 16:11
浏览:
3359
关注:
4
人
2 个回复
HelloClyde
赞同来自: rochy
Bobbao
赞同来自: