扫一扫加入大数据公众号和技术交流群,了解更多大数据技术,还有免费资料等你哦
简介
Flink提供的Kafka连接器,用于向Kafka主题读取或写入数据。Flink1.14之前使用Flink KafkaConsumer和FlinkKafkaProducer操作kafka ,但是Flink1.14之后弃用,取而代之的是KafkaSource和KafkaSink ,本文将详细介绍新老api的区别和使用方式。
| Maven 依赖 | 支持到的版本 | 生产者和消费者类的名成 | Kafka version | Notes |
|---|---|---|---|---|
| flink-connector-kafka-0.8_2.11 | 1.0.0 |
版权声明:本文为aA518189原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。
