Kafka 生产者 RecordTooLargeException

San*_*kar 6 apache-kafka kafka-producer-api

我收到以下错误

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

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

不知道为什么?谢谢

小智 5

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

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

请通过以下链接了解更多详细信息: 如何使用 Kafka 发送大消息(超过 15MB)?