Estoy buscando algunos consejos sobre cómo configurar un flujo de Spring Data Flow para un caso de uso específico.

Mi caso de uso:

Tengo 2 RDBMS y necesito comparar los resultados de las consultas ejecutadas en cada uno. Las consultas deben ejecutarse aproximadamente de manera simultánea. Según el resultado de la comparación, debería poder enviar un correo electrónico a través de una aplicación personalizada de correo electrónico que he creado.

Imagino que el diagrama de flujo se verá así (perdón por la pintura):

El problema es que SDF no permite, que yo sepa, permitir que una secuencia se componga con 2 fuentes. Me parece que algo así debería ser posible sin llevar demasiado lejos los límites del marco. Estoy buscando respuestas que brinden un buen enfoque para este escenario mientras trabajo dentro del marco SDF.

Estoy usando Kafka como agente de mensajes y el servidor de flujo de datos está usando mysql para mantener la información de la transmisión.

He considerado crear una aplicación de origen personalizada que sondea dos fuentes de datos y envía los mensajes en el canal de salida. Esto eliminaría mi requisito de 2 fuentes, pero parece que requeriría una cantidad significativa de personalización de la aplicación fuente jdbc.

Gracias por adelantado.