2016-05-02 5 views
0

Я создал композитный модуль:Spring XD Ошибка создание потока с композитным модулем с процессором оболочки в нем

module compose common-module --definition "kafka --topic=topic1 --outputType=text/plain | shell --command='script1.sh' " 

Затем я создал поток, используя этот модуль:

stream create stream1 --definition "common-module > queue:job:job1" 

И я получил следующая погрешность:

Кто-нибудь знает, что происходит? Благодаря !

ответ

2

Это ошибка, я открыл JIRA Issue.

Единственная работа вокруг я могу думать (сокр создания пользовательского модуля оболочки - см JIRA), чтобы передать в скрипт снова ...

stream create stream1 --definition "common-module --shell.script=script1.sh > queue:job:job1" 
+0

Спасибо Гэри. Итак, это будет исправлено в следующем выпуске SpringXD? – jlp

+0

Да (в соответствии с вопросом JIRA), но я не знаю, когда это будет. Я не знаю, как легко будет исправляться, я не знаком с этой частью базы кода. –

+0

Гэри, я опубликовал новый вопрос о исходном модуле SpringXD kafka. Не уверен, если у вас есть понимание. Благодарю. http://stackoverflow.com/questions/37349938/how-to-make-springxd-kafka-source-module-reads-from-where-it-left – jlp