flink 从 kafka 读取数据答案

【问题标题】：flink read data from kafkaflink 从 kafka 读取数据
【发布时间】：2016-11-08 00:23:41
【问题描述】：

我写一个简单的例子

val env = StreamExecutionEnvironment.getExecutionEnvironment
val properties = new Properties()
properties.setProperty("bootstrap.servers","xxxxxx")
properties.setProperty("zookeeper.connect","xxxxxx")
properties.setProperty("group.id", "caffrey")
val stream = env
  .addSource(new FlinkKafkaConsumer082[String]("topic", new SimpleStringSchema(), properties))
.print()

env.execute("Flink Kafka Example")

当我运行这段代码时，我得到了一个像这样的错误：

[错误] 类 org.apache.flink.streaming.api.checkpoint.CheckpointNotifier 未找到 - 继续存根。

我用谷歌搜索这个错误，发现CheckpointNotifier 是interface。我真的不明白我哪里做错了。

【问题讨论】：

标签： apache-kafka apache-flink

【解决方案1】：

由于 CheckpointNotifier 是来自旧 Flink 版本的类，我怀疑您在 pom 文件中混合了不同的 Flink 依赖项。

确保所有 Flink 依赖都具有相同的版本。

【讨论】：

我更改降级 flink 版本，它可以工作，谢谢！