【文件属性】：
文件名称：flink-streamer:在flink中使用Kafka消息并将其沉入ElasticSearch
文件大小：5KB
文件格式：ZIP
更新时间：2021-05-18 13:43:29
Java
flink-streamer
一个演示应用程序，它从kafka接收实时消息，并对它们执行一些数据处理工作，并将其最终存储到ElasticSearch中。
为什么要定制沉降片？
Flink ElasticSearch Connector仅在5.x之前的版本中支持ElasticSearch，但我使用6.2.x。 我通过使用官方的ElasticSearch Java API实现了自定义沉降片。
可视化
在将数据写入ElasticSearch之后/期间，可以在Kibana中实时显示它们。
【文件预览】：
flink-streamer-master
----src()
--------main()
----README.md(593B)
----pom.xml(2KB)
----.gitignore(514B)