Elasticsearch索引作爲apache flink批處理作業的源碼

Question

我對Apache Flink相當陌生。我有一個具體的要求是我必須使用elasticsearch索引作爲源。我試圖找出flink是否具有elasticsearch的來源，但似乎不是。我可以看到我們可以將elasticsearch作爲一個接收器，但是作爲源的直接支持不在那裏。任何人都可以指導我如何解決這個問題。我正在使用elasticsearch 5.5.0和flink 1.2。

Answer 1

我在git上發現了一個flink elasticsearcg源連接器實現 - https://github.com/mnubo/flink-elasticsearch-source-connector。但它似乎在近一年內一直沒有活躍，並且在聚合和es版本方面的支持有限。

分享這個想法，以防萬一，如果它滿足某人的要求。