Flink实战（八）Flink 使用 Kafka Source & Kafka Sink_flink cdc sql kafka source sink

作者：小惠珠哦 | 2024-07-05 05:52:10

踩

flink cdc sql kafka source sink

FlinkKafkaConnector

该连接器提供对Apache Kafka服务的事件流的访问。

Flink提供了特殊的Kafka连接器，用于从Kafka主题读写数据。 Flink Kafka Consumer与Flink的检查点机制集成在一起，以提供有且仅有一次的语义。为此，Flink不仅仅依赖于Kafka的消费者群体偏移量跟踪，还内部跟踪和检查这些偏移量。

接一下以一个示例配置来介绍一下Flink如何以读取Kafka，并且再写入到一个新的Topic中

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/小惠珠哦/article/detail/789344