0
点赞
收藏
分享

微信扫一扫

Kafka消息数据积压,Kafka消费能力不足怎么处理?

微言记 2022-04-29 阅读 51
hadoop
  1. 如果是Kafka消费能力不足,则可以考虑增加Topic的分区数,并且同时提升消费组的消费者数量,消费者数=分区数;
  2. 如果是下游的数据处理不及时,提高每批次拉取的数量。批次拉取数量太少,即拉取数量/处理时间<生产速度,使处理的数据小于生产的数据,也会造成数据挤压。

参考:https://www.cnblogs.com/lidabo/p/13671557.html

举报

相关推荐

0 条评论