Kafka連接訪問兩個接收器（ftp和sql）

Question

我需要使用kafka連接接收器將文件數據發送到ftp服務器，服務器收到整個文件後，我還必須發送確認以更改狀態這些任務在db中。

我想知道什麼是最好的方式去這裏，我最初想到創建一個自定義ftp kafka連接，這也將改變任務數據庫狀態。 這是最好的方式，還是在這裏有其他選擇？

Answer 1

驅動需要更新任務數據庫中狀態的需求是什麼？

不用擔心，我可以編寫一個自定義應用程序來跟蹤FTP接收器與可用消息的偏移量，並根據需要更新數據庫。

值得注意的是，https://www.confluent.io/product/control-center/可以跟蹤Kafka Connect管道中的消息傳遞並警告延遲。