org.apache.flink.streaming.connectors.kafka.FlinkKafkaException: Failed to send data to Kafka: The message is 1446026 bytes when serialized which is larger than the maximum request size you have configured with the max.request.size configuration.
数据太大无法发送至kafka.
需要调整produce config
sinkProperties.setProperty("max.request.size", "2148576");
broker端调整
message.max.bytes
consumer端调整
fetch.max.bytes
也可以把msg 压缩后发送
本文转载自: https://blog.csdn.net/malove110/article/details/128346156
版权归原作者 malove110 所有， 如有侵权，请联系我们删除。
版权归原作者 malove110 所有， 如有侵权，请联系我们删除。