问题: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。



