Spring Cloud Data Flow: связь между пользовательским приложением Stream и предварительно созданным приложением Stream - PullRequest
0 голосов
/ 25 мая 2018

Привет, ребята,У меня проблема с потоком данных Spring Cloud.Я не могу передать данные между предварительно созданным потоком приложений и пользовательским приложением.

ОКРУЖАЮЩАЯ СРЕДА:Версия Kafka: 0.10.2.1 (с версией 2.11 scala)Версия Spring Cloud Data Flow: 1.5.0Версия для весенней загрузки: 2.0.2

ПРОБЛЕМЫ:Я сделал туто из: https://docs.spring.io/spring-cloud-dataflow/docs/current/reference/htmlsingle/#_custom_processor_applicationЗатем я зарегистрировал пользовательское приложение с именем преобразователь (тип процессора). фотография Я создаю поток и развертываю его, используя свое собственное приложение.- проблема 1: развертывание потока пользовательских приложений никогда не заканчивается. фотография - проблема 2: я не могу перенести данные между предварительно созданным потоком приложения и пользовательским приложением.Вот стандартный вывод приложения transormer: картинка Вот стандартный вывод журнала (раковина): фотография

ЧТО Я ПОПРОБОВАЛ:- Я также пробовал это, но те же проблемы -> Custom Stream Cloud Processor - Я пробовал много других Tutos с других сайтов ..- Я пробовал разные версии kafka: 1.1.0, 1.0.1- Я прочитал документацию Spring Cloud Stream и документацию Spring Cloud Data Flow, но я не могу сказать, что не так с тем, что я сделал.

Заранее благодарим за помощь, которую вы окажете.

Ответы [ 2 ]

0 голосов
/ 07 июня 2018

Журналы, прикрепленные как изображения, не очень полезны.Если у вас все еще есть под рукой, было бы хорошо, чтобы просмотреть реальные журналы.Вы можете отредактировать исходное сообщение с помощью обратных галочек или загрузить журналы в виде сущности и связать их.

Насколько я могу судить, вы пытаетесь запустить приложение 2.x Stream против старого брокера Kafka.Тем не менее, он все равно должен отображаться в журналах как ошибки, так что рассмотрение особенностей поможет устранить его.

Кроме того, вот справочная таблица совместимости Stream и Kafka .

0 голосов
/ 25 мая 2018

Кто-то помог мне решить проблему.

С версией 2.0.2 Spring мой пользовательский поток приложений не работал.Но когда я использовал версию Spring 15.13, все заработало!

Надеюсь, это поможет некоторым людям.

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