Kafka生产者报错MESSAGE_TOO_LARGE
问题:kafka发送接收消息默认大小是1M,如果数据超过1M就会报错MESSAGE_TOO_LARGE。解决方案:1 修改kafka 安装路基config目录修改server.properties文件;修改后重启kafka#单位Bmessage.max.bytes=1024000000查看日志是否修改成功cat server.log.*|grep message.max.bytesbash-4.4
·
问题:kafka发送接收消息默认大小是1M,如果数据超过1M就会报错MESSAGE_TOO_LARGE。
解决方案:
1 修改kafka 安装路基config目录修改server.properties文件;修改后重启kafka
#单位B
message.max.bytes=1024000000
查看日志是否修改成功
cat server.log.*|grep message.max.bytes
bash-4.4# cat server.log.*|grep message.max.bytes
message.max.bytes = 1000012
message.max.bytes = 1000012
message.max.bytes = 1000012
message.max.bytes = 1000012
message.max.bytes = 1000012
message.max.bytes = 1000012
2 生产者配置max.request.size
properties.put(ProducerConfig.MAX_REQUEST_SIZE_CONFIG, 1024000000);
注意事项batch.size配置要小于max.request.size。
更多推荐



所有评论(0)