如何stop/terminate汇合JDBC源连接器?
How to stop/terminate confluent JDBC source connector?
我是 运行 汇合 JDBC 源连接器,可以从数据库 table 读取并发布到 Kafka 主题。连接器由作业调度程序启动,我需要在连接器从数据库 table 发布所有行后停止连接器。知道如何优雅地停止它吗?
您可以使用 the REST API 暂停(或删除)连接器
PUT /connectors/:name/pause
没有 "notification" 知道是否所有记录都已加载,因此在 JDBC 源中,您还可以安排长时间延迟的批量模式(比如整周),然后安排连接器删除。
要暂停它,运行 这来自命令 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”部分使其更具可读性。
我是 运行 汇合 JDBC 源连接器,可以从数据库 table 读取并发布到 Kafka 主题。连接器由作业调度程序启动,我需要在连接器从数据库 table 发布所有行后停止连接器。知道如何优雅地停止它吗?
您可以使用 the REST API 暂停(或删除)连接器
PUT /connectors/:name/pause
没有 "notification" 知道是否所有记录都已加载,因此在 JDBC 源中,您还可以安排长时间延迟的批量模式(比如整周),然后安排连接器删除。
要暂停它,运行 这来自命令 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”部分使其更具可读性。