文件名称: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、流程测试。
文件名称: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、流程测试。