一次kafka堆积问题解决

咱们从kafka获取数据，以下图，有两步，第一步是从dmq获取出来放到一个队列里；第二步是咱们消费线程从队列里获取内容。框架 对第一步，业务做为dmq客户端，启动N个链接去链接dmq，链接数由配置项mq.consumer.connections指定，通常模块都没配置（目前小组内框架设置的默认值是2） 对第二步，消费线程数是由配置项 consumer.thread.num 决定（出现问题时为10）优

>>阅读原文<<