消费者无论是否消费或消费快慢都不会影响分区本身的数据,那么消息积压到底是哪个步骤产生的问题?是否是因为未消费消息越来越多导致offset寻址变慢,进而导致消费速度越来越慢甚至服务崩溃?
消息积压是指具体的某个消费者组的,比如topic A有10万条消息,消费者组A的offset在8万的位置,那它就还有2万的积压消息没有消费。
不存在,消费者组A是通过自己记录的offset位置直接进行消费的,不存在寻址,offset就是具体数据的位置下标。
不存在,kafka的消息是落到磁盘的,按照默认7天进行依次清理,只要磁盘够写。
这么一说,消息积压不会带来性能影响?
kafka没有积压问题。
找不到想要的答案?提一个您自己的问题。
0 声望
这家伙太懒,什么都没留下
消息积压
消息积压是指具体的某个消费者组的,比如topic A有10万条消息,消费者组A的offset在8万的位置,那它就还有2万的积压消息没有消费。
offset寻址变慢?
不存在,消费者组A是通过自己记录的offset位置直接进行消费的,不存在寻址,offset就是具体数据的位置下标。
消费速度越来越慢甚至服务崩溃?
不存在,kafka的消息是落到磁盘的,按照默认7天进行依次清理,只要磁盘够写。
这么一说,消息积压不会带来性能影响?
kafka没有积压问题。
你的答案