kafka單條消息過大致使生產者程序發送到broker失敗

         今天碰到一個問題,kafka生產者罷工中止生產了,並且生產者的內存急劇升高,致使程序幾回重啓。查看日誌,才發現生產者程序爆出異常kafka.common.MessageSizeTooLargeException。html          查看kafka配置,默認單條消息最大爲1M,當單條消息長度超過1M時,就會出現發送到broker失敗,從而致使消息在producer的隊列中一
相關文章
相關標籤/搜索