Как запустить поток Spring Spring с помощью SCDF

Что такое самый простой способ запустить приложение Spring Spring Spring с использованием потока данных весеннего облака? Моя идея заключается в создании пользовательских источник с использованием связки kafka и мойка as prebuilt стартер, файл. Я создаю приложение, которое довольно простое, похожее на this. Я попытался создать исполняемую банку и зарегистрировать ее как источник с помощью оболочки потока данных, которая вообще не работала. Я уже следую за этим document.Как запустить поток Spring Spring с помощью SCDF

источник

2016-07-27 thedheeraz

Можете ли вы поделиться своим пользовательским исходным приложением? Ссылка GH, возможно? –

Вот мое исходное приложение https://github.com/Dhpandey/SpringStreamDemo/tree/master/StreamDemoApplication. Пожалуйста, предоставьте некоторое справочное руководство, чтобы начать с этого сценария. – thedheeraz

Я попытался локально запустить «StreamDemoApplication» и «StreamDemoSink» - оба приложения не могут загрузиться с различными ошибками. Мы настоятельно рекомендуем следовать руководству [get-started] (http://docs.spring.io/spring-cloud-stream/docs/current-SNAPSHOT/reference/htmlsingle/#_getting_started), загрузив приложение потока с помощью предназначенное для связывания из [Spring Initializr] (http://start.spring.io/). Только когда вы сможете успешно запускать их в качестве автономных загрузочных приложений, мы можем зарегистрироваться в Spring Cloud Data Flow и использовать его в определении потока. –

Наконец, я нашел, что это легче зарегистрировать пользовательские потоки в потоке данных весной облака,

Я был в состоянии зарегистрировать с помощью Maven координат, как описано here.

Мое решение:

Для координат, которые выглядят как

<groupId>com.streamdemo</groupId> 
<artifactId>Streamdemo</artifactId> 
<version>0.0.1-SNAPSHOT</version>

я использовал maven://com.streamdemo:Streamdemo:0.0.1-SNAPSHOT, и зарегистрированных в SCDF. Реальная команда выглядит следующим образом:

dataflow:>app register --name mysource --type source --uri maven://com.streamdemo:Streamdemo:0.0.1-SNAPSHOT

Он работал отлично. Here - это мой код для потока источника.

источник

2016-07-29 19:41:51 thedheeraz

Как запустить поток Spring Spring с помощью SCDF

ответ

Смежные вопросы