最爱老鼠吃大象 2021-02-04 16:38 采纳率: 37.5%
浏览 293
已结题

kafka消息消费时开启线程后还是很慢,而且线程开启也很慢

我做了一个kafka的消息队列,在消费的时候是使用@Async+线程池多线程消费的,现在发现这个消息消费时一点都不快,而且线程开启的也很慢,哪位大神了解过这个问题,解决这个问题必有重谢

  • 写回答

2条回答 默认 最新

  • 纯白微风 2021-02-04 17:04
    关注

    把消费线程固定一下,开启之后不要关闭消费线程了,30个分区的话最多开30个消费线程就行,开多了也只有最多30个线程拿到分区消费;

    消费线程每次上线或者下线都会触发重平衡,导致消费者与分区的对应关系发生变动,重平衡是需要时间的,这应该就是你消费慢的根本原因

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(1条)

报告相同问题?

问题事件

  • 系统已结题 8月9日
  • 已采纳回答 8月1日