флинк читать данные из кафки

Я пишу простой пример

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. Я действительно не понимаю, где я сделал не так.