0

我想了解 pulsar 如何将 debezium io connect 用于 CDC。在使用 pulsar-admin source create 创建源时，如何传递代理 url 和身份验证参数或客户端。类似于我们在使用 localrun 时所做的事情。

我运行的 cmd：bin/pulsar-admin source localrun --sourceConfigFile debezium-mysql-source-config.yaml --client-auth-plugin --client-auth-params --broker-service-url

现在我想替换它来创建一个在集群模式下运行的连接器。

4

1 回答 1

0

Localrun 是一种简化调试的特殊模式，它在普通集群之外运行。它需要额外的参数来为本地运行时创建客户端。

在集群模式下，连接器将从 Pulsar 连接器运行时/通过功能工作者配置获取客户端。您需要做的就是使用“ bin/pulsar-admin source create ...”。

于 2022-01-06T18:18:45.503 回答