有没有办法启动一组在启动spring xd的新实例时定义的蒸汽和水龙头？
场景是这样的:我们已经在我们的开发系统上做了一些原型设计,但现在我们想要构建并发布给测试团队.我们希望自动化大部分后台工作,用户只需担心流的输出,而不必担心流或其定义或部署.
为方便起见,我们可以使用任何运行时配置吗？
更新:我们当前的方法涉及编写一个shell脚本,以便对Spring API进行一些其他调用来创建和部署所需的流.
当我遇到 updateStateByKey() 函数时，我刚刚开始寻找 Spark Streaming 有状态计算的解决方案。
我试图解决的问题是：10,000 个传感器每分钟产生一个二进制值。
如果传感器报告的连续值彼此不同，我想标记它并将其作为状态更改事件发送到 Kafka。
我的假设是 updateStateByKey() 可以用于此示例，但是我并不完全了解实现相同方法的推荐方法。
我已经设法让Spring Xd工作,我可以从一个JMS代理进入数据.我可能面临的情况是,数据摄取可能来自不同的来源,因此需要我连接到不同的经纪人.根据我目前的理解,我不太清楚如何做到这一点,因为存在一个允许您只设置一个代理的JMS配置文件.
这有解决方法吗？