【发布时间】:2020-04-19 13:41:34
【问题描述】:
我正在运行融合的 JDBC 源连接器以从数据库表中读取数据并发布到 Kafka 主题。连接器由作业调度程序启动,我需要在连接器发布数据库表中的所有行后停止连接器。知道如何优雅地停止它吗?
【问题讨论】:
标签: apache-kafka apache-kafka-connect
我正在运行融合的 JDBC 源连接器以从数据库表中读取数据并发布到 Kafka 主题。连接器由作业调度程序启动,我需要在连接器发布数据库表中的所有行后停止连接器。知道如何优雅地停止它吗?
【问题讨论】:
标签: apache-kafka apache-kafka-connect
要暂停它,请从命令 shell(安装了 CURL)运行它:
curl -X PUT <host>:8083/connectors/<connector_name>/pause
要再次恢复,请使用:
curl -X PUT <host>:8083/connectors/<connector_name>/resume
要查看它是否已暂停,请使用:
curl <host>:8083/connectors/<connector_name>/status | jq
“jq”部分使其更具可读性。
【讨论】:
您可以使用the REST API 暂停(或删除)连接器
PUT /connectors/:name/pause
虽然没有“通知”来知道是否所有记录都已加载,因此在 JDBC 源中,您还可以安排具有较长时间延迟(例如一整周)的批量模式,然后安排连接器删除。
【讨论】: