java - kafka 客户端消费过慢

问题描述

问 题

现在有个topic 队列里面的数据快速增加的时候客户端消费能力跟不上造成数据的积压，现在的扩展方案是增加了消费者但是都是属于同一个group下面的，查看了下数据还是有很多，我的分区数量是大于consumer 的数量的，想问下有什么好的方法可以提升消费速度，

解决方案

1. 消费逻辑开多线程

2. 加机器,加partition

3. 消费跟不上生产, 看下消费逻辑在什么地方耗时比较高,一味地加机器或者加partition不能根本解决问题的

这篇关于java - kafka 客户端消费过慢的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！