我正在尝试将多个集合发送到消息流中收集器节点的同一输入终端,如下所示:
“out1”终端连接到 Collector 上名为“in1”的输入终端,“out2”连接到名为“env”的输入终端。我只想要一个集合中的一个 in1 和一个 env 一起。总共可能有多达 7 个集合。
在 ESQL 中,有一个 FOR 循环遍历集合并根据某些标准将消息传播到 in1 和 env 或不传播。传播语句在此 FOR 循环内。
这是 Colelctor 节点上的配置。两个输入终端的消息数都设置为“1”,因为我只想要一个集合中的一个 in1 和一个 env。
对于要创建两个集合的场景,我遇到的问题如下:
- Message1 传播到 out1 / in1
- Message1 传播到 out2 / env
- Message2 传播到 out1 / in1
- 所有处理停止。Flow 在可能到期时处于空闲状态。
- Message2 传播到 out2 / env。
看来问题出在收集器节点上,很可能是配置设置以及我如何将消息发送到输入终端。熟悉使用收集器节点的人是否看到任何明显可以纠正上述 #4 的内容?