https://github.com/IMJIU/Jkafka/blob/master/src/main/java/kafka/server/AbstractFetcherThread.java