春の雲データフローからトピックを作成するには？

Question

ストリームソースのために、私のソースの最後の読み取りレコードをkafkaの別のトピックに保存しようとしています。どのように私は春の雲データフローストリームアプリケーションでこれを達成することができます。

Answer 1

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

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

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

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