Kafka RecordTooLargeException问题解决

发表于 2017-08-17 更新于 2025-02-24 分类于大数据，实时计算阅读次数： Changyan：

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值一致。