2020
11-17
11-17
Java将CSV的数据发送到kafka的示例
为什么将CSV的数据发到kafkaflink做流式计算时，选用kafka消息作为数据源是常用手段，因此在学习和开发flink过程中，也会将数据集文件中的记录发送到kafka，来模拟不间断数据；整个流程如下：您可能会觉得这样做多此一举：flink直接读取CSV不就行了吗？这样做的原因如下：首先，这是学习和开发时的做法，数据集是CSV文件，而生产环境的实时数据却是kafka数据源；其次，Java应用中可以加入一些特殊逻辑，例如数据处理，...
继续阅读 >