Debezium io 与脉冲星答案

【问题标题】：Debezium io with pulsarDebezium io 与脉冲星
【发布时间】：2022-01-06 12:44:35
【问题描述】：

我想了解 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

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

【问题讨论】：

标签： debezium apache-pulsar pulsar

【解决方案1】：

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

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

【讨论】：

我尝试运行它，但源创建身份验证无法正常工作。我的客户失败了。
@ShreyaSinghal 我建议检查功能工作者配置以确保它具有正确的身份验证设置（如代理）。它也可能是特定于版本的东西或我缺少的东西。我建议在 pulsar 邮件列表或 Slack 中询问，并提供有关您使用的特定 pulsar 版本和配置的更多详细信息。
我使用的是 2.7.2，版本 2.9.1 为 debezium 客户端提供身份验证