Apache Flink Kafka集成

Question

我正在尝试将Apache Kafka 2.11-0.10.0.0与Apache Flink 1.1.2集成。我正在使用scala-shell来测试它，并且出现以下错误。

类org.apache.flink.streaming.api.checkpoint.CheckpointNotifier没有找到

我已经加入了org.apache.flink.streaming罐子到类路径，但是这并没有帮助。我一直导入到org.apache.flink.streaming.api.checkpoint._。这仍然没有帮助。下面是我在shell

import org.apache.flink.streaming.connectors.kafka._ 
import org.apache.flink.streaming.util.serialization.SimpleStringSchema 
import org.apache.flink._ 
import java.util._ 
val properties = new Properties() 
properties.setProperty("bootstrap.servers", "localhost:9092") 
properties.setProperty("zookeeper.connect", "localhost:2181") 
properties.setProperty("group.id", "test") 
val myFetcher = FlinkKafkaConsumer.FetcherType.NEW_HIGH_LEVEL 
val myHandler = FlinkKafkaConsumer.OffsetStore.FLINK_ZOOKEEPER 
senv.addSource(new FlinkKafkaConsumer[String]("topic", new SimpleStringSchema(), properties, myHandler, myFetcher)).print 

我已经使用FlinkKafkaConsumer081和FlinkKafkaConsumer082方法，而不是FlinkKafkaConsumer方法也试过，我仍然得到同样的错误已运行的代码。

我注意到flink-connector-kafka jar自2月16日以来没有更新过。这是错误的jar吗？我在maven中心Flink连接器卡夫卡基地2_11找到了。我应该使用那个罐子吗？

请帮助！

Answer 1

您有版本冲突。我相信那个班级在Flink 1.0中被删除了。所以你可能有一个老版本的jar。检查以确保一切都更新到Flink 1.1.2