巴中房产网站建设网店推广网站

个人博客地址：Kafka RecordTooLargeException问题解决 | 一张假钞的真实世界

Producer向Kafka写入数据时遇到异常：org.apache.kafka.common.errors.RecordTooLargeException。该异常是因为单条消息大小超过限制导致的。解决方法是将限制参数调大：

（1）server端：server.properties
message.max.bytes参数默认值为1000012，调整为适合的值，如10485760。

（2）producer端：
设置Producer的参数max.request.size的值与server端的message.max.bytes值一致。