apache flinkバッチジョブのソースとしてのElasticsearchインデックス

Question

私はApache Flinkにはかなり新しいです。私は、elasticsearchインデックスをソースとして使用する必要があるという特定の要件があります。私はflinkがelasticsearchとしてソースを持っているが、そうではないように見えることを試みた。シンクとして伸縮性検索をすることができますが、ソースが存在しないので直接サポートすることができます。誰も私がこの問題をどのように解決できるかについて私を導くことはできますか？私はelasticsearch 5.5.0とflink 1.2を使用しています。

Answer 1

私はgit-https://github.com/mnubo/flink-elasticsearch-source-connectorでflink elasticsearcgソースコネクタの実装を見つけました。しかし、それはほぼ1年間活動しておらず、集約とバージョンに関しては限られたサポートしか受けていないようです。

誰かの要件を満たしている場合に備えて、これを共有する考え。