debezium - 如何在rest api中添加/删除Pulsar中的连接器？

Question

我正在使用支持 Debezium 源连接器的 Pulsar IO 从您的数据库中获取流更改。

从文档中，很清楚如何连接到 MYSQL，

$ bin/pulsar-admin source localrun  --sourceConfigFile debezium-mysql-source-config.yaml

监控连接器

bin/pulsar-admin functions getstatus \
    --tenant <tenant> \
    --namespace <namespace> \
    --name <connector-name>

但是我看不到如何移除 Pulsar 中的连接器？

以及用于添加/删除连接器的任何其他 API？

score 0 · Accepted Answer

您可以使用删除命令删除连接器，即

bin/pulsar-admin source delete \
    --tenant <tenant> \
    --namespace <namespace> \
    --name <connector-name>

1 回答 1