0

私はカフカ接続シンクを使用してファイルサーバーにファイルデータを送信する必要があります。ファイル全体がサーバーによって受信された後、 db内のそれらのタスクのKafka 2つのシンク(ftpとsql)にアクセスするために接続する

私はここに行くには何が最善の方法を知っていると思いますが、私は最初にタスクのdbのステータスを変更するカスタムFTPカフカ接続を作成することを考えました。 これは最善の方法ですか、他のオプションがありますか?

答えて

0

タスクデータベースのステータスを更新する必要性を引き起こす要件は何ですか?

私の頭の上では、FTPシンクと利用可能なメッセージのオフセットを追跡し、必要に応じてデータベースを更新するカスタムアプリケーションを作成できます。

注目すべき点は、https://www.confluent.io/product/control-center/は、Kafka Connectパイプラインでメッセージの配信を追跡し、待ち時間を警告することです。

関連する問題