發送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
相關文章
相關標籤/搜索