Kafka處理大文件出現內存溢出 java.lang.OutOfMemoryError: Direct buffer memory

這篇文章是我在粗略學習kafka時遇到的問題和網上查閱過的資料。kafka和java我都不是很熟悉，只知道基本的概念。文章中可能有疏漏和錯誤的地方，你們參考一下就好。有錯誤拜託你們指正！php broker端 配置文件須要配置的參數 message.max.bytes : kafka 會接收單個消息size的最大限制， 默認爲1M左右。若是producer發送比這個大的消息，kafka默認會丟掉。

>>阅读原文<<