flink Lesen von Daten aus kafka

Question

ich ein einfaches Beispiel schreiben

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") 

, wenn ich diesen Code ausführen Ich habe eine Fehler wie folgt aus:

[Fehler] Klasse org.apache.flink .streaming.api.checkpoint.CheckpointNotifier nicht gefunden - Fortsetzung mit einem Stub.

Ich google diesen Fehler und finde CheckpointNotifier ist ein interface. Ich verstehe wirklich nicht, wo ich falsch gemacht habe.

Answer 1

Da CheckpointNotifier eine Klasse aus einer älteren Flink-Version ist, vermute ich, dass Sie verschiedene Flink-Abhängigkeiten in Ihrer Pom-Datei mischen.

Stellen Sie sicher, dass alle Flink-Abhängigkeiten die gleiche Version haben.