0
我有一個彈簧雲流的情況,我有一個源,一個變壓器,我需要在兩個數據庫中寫入相同的東西。我正在檢查是否有兩個接收器的選項,但我找不到一種方法來做到這一點。 對於我的情況最好的實踐中的任何建議將不勝感激!在兩個數據庫中寫入彈簧雲流
我有一個彈簧雲流的情況,我有一個源,一個變壓器,我需要在兩個數據庫中寫入相同的東西。我正在檢查是否有兩個接收器的選項,但我找不到一種方法來做到這一點。 對於我的情況最好的實踐中的任何建議將不勝感激!在兩個數據庫中寫入彈簧雲流
您可以讓多個接收器收聽相同的目的地,請參閱consumer groups。
每個組都獲取郵件的副本。
編輯
如果您使用的彈簧雲數據流,你可以用一個水龍頭:
stream create foo --definition="source | transform | sink1"
stream create bar --definition=":fooLtransform > sink2"
所以你是說我的水槽應該是卡夫卡的話題,還有其他兩個流聽那些話題並寫入兩個不同的接收器 – Marseld
不需要明確的Kafka接收器;如果您使用spring-cloud-dataflow定義流,則可以使用tap作爲第二個流的源 - [請參閱tap(http://docs.spring.io/spring-cloud-dataflow/docs/1.1 .0.RELEASE /參考/ htmlsingle /#彈簧雲數據流流抽頭-DSL)。我添加了一個例子。如果您正在編寫獨立的spring-cloud-stream應用程序,則可以簡單地配置它們以聽取相同的目標。 –