卡夫卡生产者 RecordTooLargeException

【问题标题】：Kafka Producer RecordTooLargeException卡夫卡生产者 RecordTooLargeException
【发布时间】：2017-02-21 22:58:01
【问题描述】：

我收到以下错误

org.apache.kafka.common.errors.RecordTooLargeException: 序列化时消息为 196773 字节，大于您使用 buffer.memory 配置配置的总内存缓冲区"

但我的生产者配置中的 buffer.memory 是 10485760

不知道为什么？谢谢

【问题讨论】：

【解决方案1】：

我了解您在生产者配置中的 buffer.memory 大于您正在生成的消息的大小。但是，为了生成大小超过 1 MB 的消息，您需要维护的配置很少。

message.max.bytes -（每个代理）这是代理可以从生产者那里接收到的最大消息大小。
max.message.bytes -（每个主题）这是代理允许附加到主题的最大消息大小。（默认为经纪人的message.max.bytes。）

【讨论】：