kafka消息消费的慢,不知道是消费者处理的能力不行,还是什么原因导致的。
kafka是批量获取消息的,一般默认拉取2000-3000条消息(根据消息大小,有所不同)。所以,一般都是消费者拿到消息后,你的处理跟不上。
设置的默认是 100条消息,就是消费能力太慢了
消费能力是指kafka还是你的处理程序?
应该是我的处理程序吧,每个消息过来一大堆逻辑,我用的是单分区,就一个patition
是为了保证顺序才用单分区?你这种只能优化你的处理程序了。
嗯是啊,多分区消息顺序乱了
大佬消费满解决了吗?小弟也遇到同样问题
如果你没有消息顺序保证的话:
这是最快和最优的方法。
找不到想要的答案?提一个您自己的问题。
0 声望
这家伙太懒,什么都没留下
kafka是批量获取消息的,一般默认拉取2000-3000条消息(根据消息大小,有所不同)。
所以,一般都是消费者拿到消息后,你的处理跟不上。
设置的默认是 100条消息,就是消费能力太慢了
消费能力是指kafka还是你的处理程序?
应该是我的处理程序吧,每个消息过来一大堆逻辑,我用的是单分区,就一个patition
是为了保证顺序才用单分区?
你这种只能优化你的处理程序了。
嗯是啊,多分区消息顺序乱了
大佬消费满解决了吗?小弟也遇到同样问题
如果你没有消息顺序保证的话:
这是最快和最优的方法。
你的答案