Press "Enter" to skip to content

Kafka RecordTooLargeException 问题解决

Published 2022年5月11日 by admin

需要修改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);

Published in 未分类

发表回复

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