猿问

kafka 客户端消费过慢

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

慕少森
浏览 1188回答 2
2回答

阿晨1998

消费逻辑开多线程。必然会用到线程池,机器重启的时候,消息会丢失
随时随地看视频慕课网APP

相关分类

Java
我要回答