文件名称：flink-streamer:在flink中使用Kafka消息并将其沉入ElasticSearch
文件大小：5KB
文件格式：ZIP
更新时间：2024-06-07 07:30:09
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)