Spring XD创建带有外壳处理器的Composite模块的流时出错

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问题。

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

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