Spark Scala Kafka Streaming не работает - сообщение об ошибке отсутствует - PullRequest
0 голосов
/ 12 декабря 2018

Scala Spark Streaming не подключается к темам Kafka и чтению сообщений.В журналах ошибок искры нет сообщения об ошибке, и задание искры находится в рабочем режиме.В журналах есть только сообщения до идентификатора Kafka Commit.После этого никаких журналов.

18/11/28 11:40:31 INFO AppInfoParser: версия Kafka: 0.10.0.0 18/11/28 11:40:31 INFO AppInfoParser: Kafka commitId: b8642491e78c5a13

В чем здесь проблема.Раньше все работало нормально.Я создал новые темы, но все еще такое же поведение.Пожалуйста, помогите решить ее.

...