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);

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注