我试图用这个定义创建一个流:
stream create --name test3 --definition "jms --destination=test3 --pubSub=true --subscriptionName=test3 --durableSubscription=true --clientId=cbda83 --outputType=text/plain | filter --script=file:/opt/bidpwr/app_config/spring_xd/fleet/startstop/ready1.groovy --properties-location=file:/opt/bidpwr/app_config/spring_xd/fleet/common/fleet_config.properties --inputType=application/json --outputType=application/json | log"
它抛出了这个错误:
Command failed org.springframework.xd.rest.client.impl.SpringXDException: Error with option(s) for module filter of type processor:
properties-location: option named 'properties-location' is not supported
我浏览了文档,但无法弄清楚它失败的原因。
当我运行时"info"
,我也没有看到--properties-location
列出的属性:
xd:>module info processor:filter
Information about processor module 'filter':
Option Name Description Default Type
----------- --------------------------------------------------------------- ------- --------
expression a SpEL expression to evaluate as a predicate <none> String
script location of a groovy script to use as a predicate to the filter <none> String
outputType how this module should emit messages it produces <none> MimeType
inputType how this module should interpret messages it consumes <none> MimeType
知道如何解决这个问题吗?