通过 env vars 配置 Debezium MySQL 连接器

Posted

技术标签:

【中文标题】通过 env vars 配置 Debezium MySQL 连接器【英文标题】:Configuring Debezium MySQL connector via env vars 【发布时间】:2020-05-13 13:13:45 【问题描述】:

配置 Debezium 连接器(在我的例子中是 mysql)的唯一方法是通过 HTTP 将 a config 发送到正在运行的 Kafka Connect 实例。

我的问题是:是否可以在启动 Connect 实例时提供此配置?通过属性文件或(理想情况下)通过环境变量?..

【问题讨论】:

【参考方案1】:

如果您在独立模式下执行连接器工作者,您可以通过命令行提供配置(详见here):

bin/connect-standalone worker.properties connector1.properties [connector2.properties connector3.properties ...]

对于分布式模式,只能使用REST API。但是您可以使用 Ansible 之类的工具进行一些自动化操作。

【讨论】:

啊,谢谢,不知怎的,我错过了。 Debezium 文档也错过了这一点。让我为此创建自己的 Docker 映像并尝试... 也许这是一个很好的起点:hub.docker.com/r/debezium/connect 是的,这就是我开始使用的图像。但它在内部以分布式模式运行 Kafka Connect,所以我将创建自己的一个以独立模式启动(如您所建议的那样)。 嗨,Alexey,你成功了吗?如果我们可以使用,您有链接吗?

以上是关于通过 env vars 配置 Debezium MySQL 连接器的主要内容,如果未能解决你的问题,请参考以下文章

如何通过 docker-compose 实现 debezium 连接器(Oracle)?

Laravel env vars in bootstrap / app.php?

构建后如何在 Vue.js 项目中存储 Firebase 凭据(env_var)

Debezium 是不是提供交货和订购保证?

ini 使用mod_rewrite(和mod_setenvif)通过temp env vars操作查询字符串参数的示例

GCP kms加密env var并通过cloudbuild.yaml将加密密钥传递给谷歌应用引擎