发送kafka报错:buffered messsge send to kafka err:Message size TooLarge

程序报错如下: 解决方案: 调整kafka对单条消息的大小限制:message.max.bytes从默认1M调整为10M,10M是cdh建议的最大值了,调整过大会影响kafka的吞吐量,同时需要调整replica.fetch.max.bytes的值需要大于等于message.max.bytes,该参数为broker同步的消息大小限制,如果小于message.max.bytes可能会出现broker
相关文章
相关标签/搜索