我正在使用 FlinkKafkaProducer08 向Kafka发送记录 . 但有时我得到以下异常，即使我在错误消息中打印的记录太小，大小为0.02 MB .
java.lang.RuntimeException: Could not forward element to next operator
Caused by: java.lang.RuntimeException: Could not forward element to next operator
Caused by: java.lang.Exception: Failed to send data to Kafka: The message is 1513657 bytes when serialized which is larger than the maximum request size you have configured with the max.request.size configuration.
Caused by: org.apache.kafka.common.errors.RecordTooLargeException: The message is 1513657 bytes when serialized which is larger than the maximum request size you have configured with the max.request.size configuration
试图在 生产环境 者上更改max.request.size，但这需要经纪人更改并重新启动代理 .
1 回答
最大邮件大小还有一个代理设置：
因此，您需要重新启动经纪人 - 但这应该不是问题 . Kafka在经纪人反弹方面 Build 了稳健的方式 .
参看http://kafka.apache.org/082/documentation.html#producerconfigs