2017-04-04 10 views

答えて

0

Spring Cloud Streamアプリケーションは、複数の宛先をサポートできます。

2つ目の出力先を追加してメッセージを送信できます。

ソースとしてRDBMSを使用します。現在のJDBCアプリケーションのスターターは、行を読み取りとしてマークするために、ソーステーブルに余分なフラグが必要です。しかし、シナリオのほとんどは可能ではありません。だから、タイムスタンプに基づいて構築しようとしています。別のトピックの最後の読み込みタイムスタンプ..そして、このタイムスタンプを使用するたびに、RDBMSから読み込みを継続します(インクリメンタルロード)

起動時にトピックから消えて最初の開始値を得ることができます。

+0

応答のためにありがとう。目的は、それが停止した時点から続けることです...私は2番目の出力先を使用する場合、私の理解に従って、私はそれを読むことができませんソースストリームを継続してください。間違っていれば私を訂正してください。 – shelzz

+0

バインダーはすでにオフセットをコミットしているので、途中から開始します。 –

+0

RDBMSをソースとして使用したいと考えています。現在のJDBCアプリケーションのスターターは、行を読み取りとしてマークするために、ソーステーブルに余分なフラグが必要です。しかし、シナリオのほとんどは可能ではありません。だから、タイムスタンプに基づいて構築しようとしています。別のトピックの最後の読み取りタイムスタンプ..毎回私はこのタイムスタンプを使用して、RDBMS(インクリメンタルロード)からの読み取りを続けます。 – shelzz

関連する問題