弹簧数据流w/2源提供一个处理器/接收器

Question

我正在寻找建立一个特定用例的Spring数据流流的建议。

我的使用情况：

我有2 RDBMS，我需要比较针对每个运行的查询的结果。查询应该大致同时运行。根据比较结果，我应该可以通过我创建的自定义电子邮件接收器应用程序发送电子邮件。

我设想流图看起来像这样（对不起，油漆）：

的问题是，日本自卫队没有，据我所知，允许流与2个源组成。在我看来，像这样的事情应该是可能的，而不必将框架的限制推得太远。我正在寻找解决方案，在SDF框架内工作时为这种情况提供了一个很好的方法。

我使用Kafka作为消息代理，数据流服务器使用mysql来保存流信息。

我已经考虑创建一个自定义的源应用程序，它轮询两个数据源并在输出通道上发送消息。这将消除我对2个源的需求，但看起来它需要对jdbc源应用程序进行大量的定制。

在此先感谢。

Answer 1

我还没有真正尝试过这种方式，但是您应该可以使用命名的目标来实现这一点。看看这里：http://docs.spring.io/spring-cloud-dataflow/docs/current-SNAPSHOT/reference/htmlsingle/#spring-cloud-dataflow-stream-advanced

stream create --name jdbc1 --definition "jdbc > :dbSource"

stream create --name jdbc2 --definition "jdbc > :dbSource"

stream create --name processor --definition ":dbSource > aggregator | sink"