2017-01-09 14 views
0

私は1つのソースと1つのトランスを持つ春のクラウドストリームの状況があり、同じことを2つのデータベースに書き込む必要があります。私は2つのシンクを持つオプションがあるかどうかをチェックしていましたが、その方法を見つけることができません。 私の場合のベストプラクティスの提案は非常に高く評価されます!2つのデータベースにSpringクラウドストリームを書き込む

答えて

1

同じ宛先をリッスンする複数のシンクを持つことができます。consumer groupsを参照してください。

各グループはメッセージのコピーを取得します。

EDIT

あなたは春・クラウド・データフローを使用している場合は、タップを使用することができます。

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

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

だからあなたが私のシンクはカフカの話題も他の二つのストリームを持つべきであることを示唆していますそれらの話題を聞いて2つの異なるシンクに書き込む – Marseld

+0

カフカシンクを明示する必要はありません。 spring-cloud-dataflowを使用してストリームを定義する場合は、2番目のストリームのソースとしてタップを使用できます - [タップを参照](http://docs.spring.io/spring-cloud-dataflow/docs/1.1 .0.RELEASE/reference/htmlsingle /#spring-cloud-dataflow-stream-tap-dsl)。私は例を追加しました。スタンドアローンのSpring Cloud Streamアプリケーションを作成する場合は、両方を同じ宛先を聴くように設定するだけです。 –

関連する問題