Kafka消息积压产生的根源和机制是什么?

冷メ残冰 发表于: 2021-12-16   最后更新时间: 2021-12-16 15:37:44   159 游览

消费者无论是否消费或消费快慢都不会影响分区本身的数据,那么消息积压到底是哪个步骤产生的问题?是否是因为未消费消息越来越多导致offset寻址变慢,进而导致消费速度越来越慢甚至服务崩溃?



发表于 2021-12-16
添加评论

消息积压

消息积压是指具体的某个消费者组的,比如topic A有10万条消息,消费者组A的offset在8万的位置,那它就还有2万的积压消息没有消费。

offset寻址变慢?

不存在,消费者组A是通过自己记录的offset位置直接进行消费的,不存在寻址,offset就是具体数据的位置下标。

消费速度越来越慢甚至服务崩溃?

不存在,kafka的消息是落到磁盘的,按照默认7天进行依次清理,只要磁盘够写。

冷メ残冰 -> 半兽人 1月前

这么一说,消息积压不会带来性能影响?

半兽人 -> 冷メ残冰 1月前

kafka没有积压问题。

你的答案

查看kafka相关的其他问题或提一个您自己的问题
提问