하나의 프로세서/싱크에 공급되는 2 개의 소스가있는 스프링 데이터 플로우

Question

특정 유스 케이스에 대한 스프링 데이터 플로우 스트림 설정에 대한 조언을 찾고 있습니다.

내 사용 사례 :

내가이 RDBMS를 가지고 있고 각각에 대해 실행 쿼리의 결과를 비교해야합니다. 쿼리는 대략 동시에 실행해야합니다. 비교 결과에 따라 필자가 만든 사용자 지정 전자 메일 싱크 응용 프로그램을 통해 전자 메일을 보낼 수 있어야합니다. 내 지식

문제는, SDF하지 않는 것입니다 스트림 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"