1、kafka版本0.8.1.1,jdk1.8
2、kafka topic有三個磁區,程式中消費者啟動3個執行緒
3、程式啟動后占用記憶體達到2G
4、使用mat分析 kafka.consumer.ConsumerIterator占了好多,但是并沒有記憶體溢位,維持在2個G不在增加
5、我懷疑是kafka消費者把訊息快取到本地導致的
6、大神給分析分析?
下面是mat的記憶體分析截圖
轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/54864.html
標籤:Spark
