通过 env vars 配置 Debezium MySQL 连接器

Question

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

我的问题是：是否可以在启动连接实例时提供此配置？通过属性文件或(理想情况下(通过 env vars?..

Answer 1

如果在独立模式下执行连接器工作线程，则可以通过命令行提供配置(请参阅此处的详细信息(：

bin/连接独立工作器.属性连接器1.属性 [连接器2.属性连接器3.属性...]

对于分布式模式，只能使用 REST API。但是您可以使用Ansible等工具进行一些自动化。