通过环境变量配置 Debezium MySQL 连接器

Question

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

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

Answer 1

如果您在 独立 模式下执行连接器工作程序，您可以通过命令行提供配置（查看详细信息 here）：

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

对于分布式模式，只能使用REST API. But you can do some automation using tools like Ansible.