我做了一个kafka的消息队列,在消费的时候是使用@Async+线程池多线程消费的,现在发现这个消息消费时一点都不快,而且线程开启的也很慢,哪位大神了解过这个问题,解决这个问题必有重谢
2条回答 默认 最新
- 纯白微风<alert> 2021-02-04 17:04关注
把消费线程固定一下,开启之后不要关闭消费线程了,30个分区的话最多开30个消费线程就行,开多了也只有最多30个线程拿到分区消费;
消费线程每次上线或者下线都会触发重平衡,导致消费者与分区的对应关系发生变动,重平衡是需要时间的,这应该就是你消费慢的根本原因
本回答被题主选为最佳回答 , 对您是否有帮助呢?解决 1无用
悬赏问题
- ¥15 基于单片机的靶位控制系统
- ¥15 AT89C51控制8位八段数码管显示时钟。
- ¥15 真我手机蓝牙传输进度消息被关闭了,怎么打开?(关键词-消息通知)
- ¥15 下图接收小电路,谁知道原理
- ¥15 装 pytorch 的时候出了好多问题,遇到这种情况怎么处理?
- ¥20 IOS游览器某宝手机网页版自动立即购买JavaScript脚本
- ¥15 手机接入宽带网线,如何释放宽带全部速度
- ¥30 关于#r语言#的问题:如何对R语言中mfgarch包中构建的garch-midas模型进行样本内长期波动率预测和样本外长期波动率预测
- ¥15 ETLCloud 处理json多层级问题
- ¥15 matlab中使用gurobi时报错