apache-kafka - 如何停止/终止融合的 JDBC 源连接器？

Question

我正在运行融合的 JDBC 源连接器以从数据库表中读取并发布到 Kafka 主题。连接器由作业调度程序启动，我需要在连接器发布数据库表中的所有行后停止连接器。知道如何优雅地停止它吗？

标签： apache-kafkaapache-kafka-connect

Answer 1

您可以使用REST API暂停（或删除）连接器

PUT /connectors/:name/pause

但是，没有“通知”来知道是否所有记录都已加载，因此在 JDBC 源中，您还可以安排具有较长时间延迟（例如一整周）的批量模式，然后安排连接器删除。