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

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

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

  • 写回答

2条回答 默认 最新

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

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

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

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
  • 纯白微风 2021-02-04 16:44
    关注

    topic分区有几个，线程怎么配置的，你的数据处理逻辑是怎样的，业务处理与消费偏移量提交操作是不是串行的，topic是否有堆积

    评论
查看更多回答(1条)

报告相同问题？

问题事件

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

悬赏问题

  • ¥15 spyder运行重复
  • ¥15 我考考你，这代码是对的还是错的？
  • ¥15 我用C语言easyx图形库绘制了一个3d游戏方框透视，但进入游戏时候鼠标准星对准方框边缘 鼠标光标就会弹出来这是啥情况怎样让光标对准绘制的方框点击鼠标不弹出光标好烦这样
  • ¥20 用Power Query整合的问题
  • ¥20 基于python进行多背包问题的多值编码
  • ¥15 相同型号电脑与配置，发现主板有一台貌似缺少了好多元器件似的，会影响稳定性和使用寿命吗？
  • ¥15 C语言：数据子序列基础版
  • ¥20 powerbulider 导入excel文件，显示不完整
  • ¥15 paddle训练自己的数据loss降不下去
  • ¥20 用matlab的pdetool解决以下三个问题