kafka 消息堆积慢消费问题

一. 问题描述         咱们的物料筛选排序系统以前常常会出现操做效果延迟的状况。在筛选排序数据不对时，咱们通常会查看ES里存储的数据和DB里存储的数据是否一致，发如今一段时间内确实会存在数据不一致。咱们怀疑是数据流下发存在延迟，因而马上查看了kafka里消息增量数量的监控，发现出问题时kafka消息增量通常都堆积比较严重，并且看kafka的消息数变化曲线，消息堆积被消费后降低的速度要明显慢

>>阅读原文<<