Flink DataSet Kafka Sink_flink dataset<string> 发送kafka-CSDN博客

网站介绍:文章浏览阅读3.8k次,点赞3次,收藏8次。1. 说明Flink 一般都是用于realtime 计算的,不过其中的 DataSet 也提供了batch API。本人在项目中也好奇试用了下,其中遇到一个需求就是把DataSet的数据Sink到 Kafka。需要注意的是Flink 官方的DataSet是不提供Kafka Sink API的,需要自己实现。当然也分 DataSet 数据量的大小,有不同的实现方式。2. 小数据量这个..._flink dataset 发送kafka