Elasticsearch index 作为 apache flink 批处理作业的来源

Question

我对Apache Flink相当陌生。我有一个特定的要求，我必须使用弹性搜索索引作为源。我试图弄清楚 flink 是否有作为弹性搜索的来源，但似乎没有。我可以看到我们可以将 elasticsearch 作为接收器，但直接支持作为源不存在。谁能指导我如何解决这个问题。我正在使用 elasticsearch 5.5.0 和 flink 1.2。

Answer 1

我，在 git - https://github.com/mnubo/flink-elasticsearch-source-connector 上找到了一个 flink elasticsearcg 源连接器实现。但它似乎已经将近一年没有活跃了，并且在聚合和 es 版本方面的支持有限。

想到分享这个以防万一它满足某人的要求。