如何从Apache Flink写入Elasticsearch

Question

我正在尝试将Flink连接到Elasticsearch，当我运行Maven项目时，我遇到了这个错误：

或者其他方式，我使用这个例子：https://github.com/keiraqz/KafkaFlinkElastic

Answer 1

您链接的示例取决于具有不同版本的各种Flink模块，这是非常不鼓励的。尝试将它们全部设置为一个版本，看看是否可以解决问题。