集成apache flink、elasticsearch和kafka的版本

Question

我对Flink，Kafka和Elastic Search的不同版本有问题。我使用的是Flink 1.8.1版本，但我不知道该使用哪个版本的Kafka。另一方面，我想使用版本6进行弹性搜索。你认为哪些版本适合Flink，Kafka和Elastic Search？下面的链接是Kafka的一个版本，但在评论部分，它是作为测试版enter link description here介绍的

Answer 1

如表中所示，Kafka 0.11 (及更高版本)将运行良好。测试版是Flink连接器的一个版本，而不是Kafka本身

此外，如果您选择使用Kafka Connect for Elasticsearch，它适用于elasticsearch 6

Answer 2

正如@cricket_007所说，使用Kafka连接器是安全的，即使它被标记为beta (这应该被移除，因为这个连接器已经在生产中进行了一年多的战斗测试)。

设置Kafka -> Flink -> ES6是很常见的，所以你可以而且应该在所有涉及的组件上使用最新版本。