Пример API потоков Kafka KStream не может быть преобразован в тип

Я работаю через этот учебник Кафка потоков

https://kafka.apache.org/0110/documentation/streams/tutorial

на машине Centos 7 под управлением JRE 8+ и Kafka 0.11.0.1

Это строка, которая выдает ошибку компиляции

KStream<String, String> source = builder.stream("streams-plaintext-input");

Пытаясь скомпилировать пример LineSplit, я получаю исключение Java

KStream cannot be resolved to a type

Будучи нубом Java, я не уверен, как решить эту проблему. Дважды проверил декларации импорта и даже скопировал образец напрасно.

Любые приводит о том, как решить эту проблему высоко ценится.

1 ответ

Решение

Пожалуйста, прочитайте учебник о Java. (Также, пожалуйста, отредактируйте свой вопрос, включив весь код и способ его компиляции.)

Вы должны убедиться, что

  • импортировать все необходимые классы в вашем коде
  • предоставить соответствующие библиотеки компилятору

Я бы порекомендовал использовать IDEA (например, Intellij или Eclipse) и использовать инструмент сборки, такой как Maven или Gradle.

Из этого туториала Вы узнаете, как настроить проект maven для вашего проекта Kafka Streams: http://kafka.apache.org/0110/documentation/streams/tutorial

Другие вопросы по тегам