我正在运行confluent JDBC源连接器,以读取DB表并发布到Kafka主题。连接器是由作业调度程序启动的,我需要在连接器发布完DB表中的所有行之后停止它。你知道如何优雅地阻止它吗?
发布于 2019-12-31 07:00:31
可以使用the REST API暂停(或删除)连接器
PUT /connectors/:name/pause
但是,没有“通知”来知道是否加载了所有记录,因此在JDBC Source中,您还可以计划具有较长时间延迟(例如一整周)的批量模式,然后计划连接器删除。
发布于 2021-07-07 06:43:32
要暂停它,可以从命令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“部分使其更具可读性。
https://stackoverflow.com/questions/59537115
复制相似问题