Flink - FlinkKafkaConsumer08

先看

基于kafka 0.8版本的fetcher，

核心的函數，是重寫

其他一些接口實作，

下面來看看simpleconsumerthread

核心函數run，主要做的是，不停的讀取資料的事情，

最後，看看

這個是對所有版本kafka的抽象，

針對kafka0.8的consumer