Apache Kafka
接入kafka对应的maven：
| maven dependency | flink支持版本 | consumer／producer名 | kafka对应版本 | 附注 |
|---|---|---|---|---|
| flink-connector-kafka-0.8_2.10 | 1.0.0 | FlinkKafkaConsumer08 FlinkKafkaProducer08 | 0.8.x | 支持SimpleConsumer |
| flink-connector-kafka-0.9_2.10 | 1.0.0 | FlinkKafkaConsumer09 FlinkKafkaProducer09 | 0.9.x | 支持new Consumer API |
| flink-connector-kafka-0.10_2.10 | 1.2.0 | FlinkKafkaConsumer010 FlinkKafkaProducer010 | 0.10.x | 可以对kafka消息添加时间戳 |