Press "Enter" to skip to content

Kafka RecordTooLargeException 问题解决

需要修改3个地方:

server.properties

message.max.bytes=52428800

producer.properties

max.request.size=52428800

java代码里面的

ProducerConfig.MAX_REQUEST_SIZE_CONFIG

props.put(ProducerConfig.MAX_REQUEST_SIZE_CONFIG, 52428800);

发表评论

您的电子邮箱地址不会被公开。