flink消费kafka数据存储到elasticsearch的演示deno

时间:2022-07-23 00:29:35
【文件属性】:

文件名称:flink消费kafka数据存储到elasticsearch的演示deno

文件大小:148.13MB

文件格式:JAR

更新时间:2022-07-23 00:29:35

flink kafka elasticsearch

1、flink监听localhost的kafka,作为source,接收数据。 2、数据流转到elasticsearch 3、flink web ui提交jar文件,创建任务流程。 4、流程测试。


网友评论