我对Apache·Flink相当陌生。我有一个具体的要求是我必须使用ElasticSearch索引作为一个来源。我试图弄清楚flink是否有elasticsearch的来源，但似乎没有。我可以看到，我们可以将elasticsearch作为一个接收器，但作为一个来源的直接支持是不存在的。有谁能指导我如何解决这个问题吗。我正在使用elasticsearch 5.5.0和flink 1.2。
我对Apache·Flink相当陌生。我有一个具体的要求是我必须使用ElasticSearch索引作为一个来源。我试图弄清楚flink是否有elasticsearch的来源，但似乎没有。我可以看到，我们可以将elasticsearch作为一个接收器，但作为一个来源的直接支持是不存在的。有谁能指导我如何解决这个问题吗。我正在使用elasticsearch 5.5.0和flink 1.2。
1条答案
按热度按时间tzdcorbm1#
i、 在git上找到一个flink elasticsearcg源连接器实现-https://github.com/mnubo/flink-elasticsearch-source-connector. 但它似乎已经不活跃了将近一年了，而且在聚合和es版本方面支持有限。
我想分享一下，以防它满足了别人的要求。