Я настроил двухузловый рабочий и один диспетчер узлов WSO2 SP кластер.Но когда я передаю свое правило диспетчеру, кажется, что оно развертывается в рабочем узле, так как выводится журнал "Приложение Siddhi siddhi-app-name-1 siddhi-app-name-1, успешно развернуто в ResourceNode {id:wso2-sp-worker-33-123, хост: 10.112.33.123, порт: 9090} . но когда я заглядываю в wso2 / worker / deplyment / siddhi-файлы в 10.112.33.123, он не отображается.
Так, где это развернуто?
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;'