前面的图可以看出,读取CSV再发送消息到kafka的操作是Java应用所为,因此今天的主要工作就是开发这个Java应用,并验证;上述五个类即可完成Java应用的工作,接下来开始编码吧;如果您不想写代码,您可以直接从GitHub下载这个工程的源码,地址和链接信息如下表所示:。至此,通过Java应用模拟用户行为消息流的操作就完成了,接下来的flink实战就用这个作为数据源;

Java将CSV的数据发送到kafka的示例

Java将CSV的数据发送到kafka的示例

Java将CSV的数据发送到kafka的示例

Java将CSV的数据发送到kafka的示例

Java将CSV的数据发送到kafka的示例

Java将CSV的数据发送到kafka的示例

Java将CSV的数据发送到kafka的示例

Java将CSV的数据发送到kafka的示例

Java将CSV的数据发送到kafka的示例