Я пытаюсь запустить простую тестовую программу с KinkkaSource от Flink. Я использую следующее:

Флинк 0,9Scala 2.10.4Кафка 0.8.2.1

Я следовал документации, чтобы проверить KafkaSource (добавили зависимости, связали соединитель Kafka flink-connector-kafka в плагине), как описаноВот а такжеВот.

Ниже моя простая тестовая программа:

import org.apache.flink.streaming.api.scala._
import org.apache.flink.streaming.connectors.kafka

object TestKafka {
  def main(args: Array[String]) {
    val env = StreamExecutionEnvironment.getExecutionEnvironment
    val stream = env
     .addSource(new KafkaSource[String]("localhost:2181", "test", new SimpleStringSchema))
     .print
  }
}

Тем не менее, компиляция всегда жалуется, что KafkaSource не найден:

[ERROR] TestKafka.scala:8: error: not found: type KafkaSource
[ERROR]     .addSource(new KafkaSource[String]("localhost:2181", "test", new SimpleStringSchema))

Что мне здесь не хватает?