异常消息:

org.apache.kafka.common.errors.RecordTooLargeException: The message is 6414622 bytes when serialized which is larger than the maximum request size you have configured with the max.request.size configuration.

快速对策:调整kafka服务参数

修改前=>

修改后=>

问题本质:

有应该是个别消息体过大,导致批量发送序列化失败,所以既可以调整kafka服务参数,可以从业务逻辑入手,删除冗余内容减小消息体Size。

Logo

魔乐社区(Modelers.cn) 是一个中立、公益的人工智能社区,提供人工智能工具、模型、数据的托管、展示与应用协同服务,为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作,由全产业链共同建设、共同运营、共同享有,推动国产AI生态繁荣发展。

更多推荐