Spark Streaming Context блокирует конечные точки REST - PullRequest
0 голосов
/ 20 декабря 2018

Я работаю над небольшим проектом с использованием Spring Boot, Kafka и Spark.До сих пор мне удавалось создать производителя Kafka в одном проекте и прямой поток Spark-Kafka в качестве потребителя.

Я вижу, как проходят сообщения, и кажется, что все работает так, как задумано.Тем не менее, у меня есть конечная точка отдыха в проекте, на котором работает потребитель.Всякий раз, когда я отключаю прямой поток, конечная точка работает нормально.Однако, когда у меня запущен поток, Почтальон говорит, что ответа нет.Я не вижу ничего в журналах сервера, указывающих, что запрос был когда-либо получен либо.

Потребитель Spark запускается компонентом при запуске проекта.Сохраняет ли это нормальный сервер на localhost: 8080 от запуска?

1 Ответ

0 голосов
/ 20 декабря 2018

Изначально я запускал StreamingContext, комментируя его как Бин.Вместо этого я заставил приложение реализовать CommandLineRunner, и в переопределенном методе run я вызвал метод, который запускает потоковый контекст.Это позволило Apache запустить и устранить проблему.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...