2017-01-09 9 views
0

나는 하나의 소스, 하나의 변환기가있는 스프링 클라우드 스트림 상황이 있으며 두 데이터베이스에 똑같은 것을 써야합니다. 나는 2 개의 싱크가있는 선택권이 있는지 검사하고 있었다 그러나 나는 그것을하는 방법을 찾아 낼 수 없다. 제 사례에 대한 모범 사례가 있으면 큰 도움이 될 것입니다.두 데이터베이스의 스프링 클라우드 스트림 작성하기

답변

1

동일한 대상을 청취하는 여러 싱크가 consumer groups을 참조 할 수 있습니다.

각 그룹은 메시지 사본을받습니다.

편집

당신이, 당신이 탭 사용할 수있는 스프링 클라우드 데이터 흐름을 사용하는 경우 : 그래서 당신이 내 싱크는 카프카의 화제와 두 개의 다른 스트림을 가져야한다고 제안하는

stream create foo --definition="source | transform | sink1" 

stream create bar --definition=":fooLtransform > sink2" 
+0

을 그 주제를 듣고 두 개의 다른 싱크대에 글을 쓰는 것 – Marseld

+0

카프카 싱크가 필요하지 않습니다. spring-cloud-dataflow를 사용하여 스트림을 정의하는 경우 탭을 두 번째 스트림의 소스로 사용할 수 있습니다. [taps 참조] (http://docs.spring.io/spring-cloud-dataflow/docs/1.1 .0.RELEASE/reference/htmlsingle/# spring-cloud-dataflow-stream-tap-dsl). 나는 예제를 추가했다. 독립 실행 형 Spring-Cloud-Stream 앱을 작성하는 경우 동일한 대상을 청취하도록 구성 할 수 있습니다. –