1, kafka version 0.8.1.1 jdk1.8
2, kafka topic has three partitions, consumers started three threads in the program
3, the program starts to 2 g memory
4, the use of mat analysis kafka. Consumer. ConsumerIterator accounted for a lot, but there is no memory, maintain in 2 G is not add
5, I doubt is caused by kafka consumer message buffer to the local
6, the great god give analysis analysis?
Here is the mat memory analysis screenshot