flink实战--flink整合kafka (kafka source 与 kafka sink)

📅 2026/8/28 1:32:43
flink实战--flink整合kafka (kafka source 与 kafka sink)
扫一扫加入大数据公众号和技术交流群,了解更多大数据技术,还有免费资料等你哦简介 Flink提供的Kafka连接器,用于向Kafka主题读取或写入数据。Flink1.14之前使用Flink KafkaConsumer和FlinkKafkaProducer操作kafka ,但是Flink1.14之后弃用,取而代之的是KafkaSource和KafkaSink ,本文将详细介绍新老api的区别和使用方式。Maven 依赖支持到的版本生产者和消费者类的名成Kafka versio