Flink Sink介绍

作者：羊村懒王 | 2024-05-22 05:17:45

踩

flink sink

Sink 是 Flink 三大逻辑结构之一（Source，Transform，Sink），功能就是负责把 Flink 处理后的数据输出到外部系统中，Flink 的 Sink 和 Source 的代码结构类似。

在编写代码的过程中，我们可以使用 Flink 已经提供的 Sink，如 Kafka，JDBC，ES等，当然我们也可以通过自定义的方式，来实现我们自己的 Sink。

1.Kafka Sink

使用官方提供的 FlinkKakfaProducer

尽请期待

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