KTableデータを外部DBに格納

私はKTableにデータを入れ、そのデータをOracle 11g DBに格納する必要があるというシナリオを持っています。可能な方法は何ですか？KTableデータを外部DBに格納

2017-10-09 Amit

あなたが望むのは、データを 'KTable'に入れるだけですか？変換などなしで？ – Arek

Kafka Connectと対応するコネクタを見てください：https://www.confluent.io/product/connectors/ –

@Arekはい一致するテーブル名を持つデータだけを置くような変換を実行する必要があります。 – Amit

Kafka StreamsからDBに書き込むことは副作用として扱われ、DBトランザクションなどではあなた自身で処理されます。私が示唆しているのは、Kafka Streamsアプリケーションでフィルタリングを行い、データを別の話題に戻すその後、@Matthias J. Saxは、Kafka Connectを利用してそのトピックを消費し、データをRDBMSに書き込むことを提案しました。

出典

2017-10-10 09:02:21 Arek

Kafka Connectは簡単な変換のための "単一メッセージ変換"もサポートしています。変換が簡単であれば、Kafkaストリームは必要ありません。 –

KTableデータを外部DBに格納

答えて

関連する問題