Flink - FlinkKafkaConsumer08

先看

基于kafka 0.8版本的fetcher，

核心的函数，是重写

其他一些接口实现，

下面来看看simpleconsumerthread

核心函数run，主要做的是，不停的读取数据的事情，

最后，看看

这个是对所有版本kafka的抽象，

针对kafka0.8的consumer