我已经建立了一个两个节点工作人员和一个单节点管理器 WSO2 SP 集群。但是当我将我的规则推送给管理器时,它似乎将它部署在工作节点中,因为它打印出日志“Siddhi app siddhi-app-name-1 of siddhi-app-name-1 成功部署在 ResourceNode { id: wso2-sp -worker-33-123, host: 10.112.33.123, port: 9090 } . 但是当我查看 10.112.33.123 中的 wso2/worker/deplyment/siddhi 文件时,它没有出现。
那么它部署在哪里呢?
my query is as follows:
@App:name("siddhi-app-name-1")
@App:description("rule for siddhi-app-name-1")
@source(
type="kafka",topic.list="input-topic",
group.id="group1",threading.option="single.thread",
bootstrap.servers="<list of kafka brokers>",
@map(type="json"))
define stream inputstream (tag_id string, tag_type int, timestamp long, value double, quality int, datatype string);
@sink(
type="kafka",
topic="output-topic",
bootstrap.servers="<list of kafka brokers>",
@map(type="json"))
Define stream outputstream (message string);
@dist(execGroup="group1")
from inputstream[name=="penta"]
select tag_id as message
insert into outputstream;'