这知识怎么不进脑子啊 2022-10-25 09:26 采纳率: 75%
浏览 169
已结题

Springboot集成kafka,应用很卡,消费很慢

Springboot集成kafka,一段时间后(大概10小时左右)应用变得很卡,消费很慢。
体现为:
1.该应用的接口响应速度很慢(10s左右,应用启动越久越慢)
2.kafka中有大量消息堆积。处理逻辑非常简单(收到数据后,更新数据库,然后通过websocket推送到前端页面,数据频率3s一次。)正常来说这种数据量不应该导致消息堆积的(10小时大概堆积10W+)
3.应用重启后恢复正常,消费速度变的正常,迅速消费完堆积的消息。接口响应速度正常
已做的处理:
1.之前topic的partition为1,现扩展为2.(broker为2,固定不变)
2.消费者使用的是@KafkaListener,没有设定concurrency值(不太清楚该值效果,应用只启了一个实例,不知道有没有用)

处理之后情况并没有得到好转。应用日志并没有打印报错,感觉像是哪里卡住了,但日志没有反应看不出来。
请教各位有无优化建议,而且想不明白是什么原因导致的应用接口变慢(查询接口,表中只有几条数据)

  • 写回答

5条回答 默认 最新

  • 夜郎king 2022博客之星IT其它领域TOP 12 2022-10-25 09:37
    关注

    感觉消息堆积有点厉害,查一下代码,是因为什么原因导致消息一直没被消费。如果只是前端数据,可以丢弃的话,把队列清空,看看还会不会卡?

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

报告相同问题?

问题事件

  • 系统已结题 4月29日
  • 已采纳回答 4月21日
  • 创建了问题 10月25日

悬赏问题

  • ¥15 如何用QDomDocument读取内容为空格的xml数据
  • ¥15 请阅读下面代码,帮我修改下代码
  • ¥15 关于#microsoft#的问题:电脑启动后不显示桌面图标和窗口,除任务栏外无法操作任何东西
  • ¥15 如何输入百度,显示本地下载的html文件页面,地址栏还显示百度的地址
  • ¥15 通过kinect制作换装程序但是服装不贴合(标签-ar)
  • ¥20 matlab如何绘制三维瀑布图
  • ¥15 关于用abap来解决动态规划的问题,但是要求输出索引值,这个是难点
  • ¥15 在ISIS中什么是IP从地址
  • ¥15 压测时,并发量过高时,响应时间出现尖刺
  • ¥15 关于vmprotect3.8.4虚拟文件一项