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

扫一扫加入大数据公众号和技术交流群,了解更多大数据技术,还有免费资料等你哦

简介

           Flink提供的Kafka连接器,用于向Kafka主题读取或写入数据。Flink1.14之前使用Flink KafkaConsumer和FlinkKafkaProducer操作kafka ,但是Flink1.14之后弃用,取而代之的是KafkaSource和KafkaSink ,本文将详细介绍新老api的区别和使用方式

Maven 依赖支持到的版本 生产者和消费者类的名成Kafka versionNotes
flink-connector-kafka-0.8_2.111.0.0

版权声明:本文为aA518189原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。