Spring XD 使用包含 shell 处理器的复合模块创建流时出错

Question

我创建了一个复合模块：

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

然后我使用这个模块创建了一个流：

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

我收到以下错误：

Command failed org.springframework.xd.rest.client.impl.SpringXDException: 
Error with option(s) for module common-module of type source:
command: may not be null
command: may not be empty

有人知道这是怎么回事吗？谢谢！

Answer 1

这是一个错误，我打开了一个JIRA Issue。

我能想到的唯一解决方法（除了创建自定义 shell 模块 - 请参阅 JIRA）是再次传入脚本...

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

Spring XD 使用包含 shell 处理器的复合模块创建流时出错

Spring XD Error creating streams with Composite module with shell processor in it

spring-xd