个人博客地址: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
值一致。