流批一体计算引擎-11-[Flink]实战使用DataStream对接kafka

1 消费kafka[DataStreamAPI]

参考官网DataStream API 教程
参考官网DataStream中的Apache Kafka 连接器

flink 1.14版本及以前,不支持python
flink 1.15版本为FlinkKafkaConsumer和FlinkKafkaProducer
flink 1.16版本及以后为KafkaSource和KafkaSink
pip install apache-flink==1.16.3
(1)Apache Flink集成了通用的Kafka连接器，
它会尽力与Kafka client的最新版本保持同步。