Kafka连接访问两个接收器（ftp和sql）

Question

我需要使用kafka连接接收器将文件数据发送到ftp服务器，服务器收到整个文件后，我还必须发送确认以更改状态这些任务在db中。

我想知道什么是最好的方式去这里，我最初想到创建一个自定义ftp kafka连接，这也将改变任务数据库状态。 这是最好的方式，还是在这里有其他选择？

Answer 1

驱动需要更新任务数据库中状态的需求是什么？

不用担心，我可以编写一个自定义应用程序来跟踪FTP接收器与可用消息的偏移量，并根据需要更新数据库。

值得注意的是，https://www.confluent.io/product/control-center/可以跟踪Kafka Connect管道中的消息传递并警告延迟。