Kafka 连接器是否可以加载自己的名称

Question

根据Kafka文档

连接器配置是简单的键值映射。对于独立 模式 这些在属性文件中定义并传递给连接 命令行上的进程。

大多数配置都依赖于连接器，因此无法概述它们 这里。但是，有几个常见的选项：

name - Unique name for the connector. Attempting to register again with the same name will fail.

我有 10 个连接器在独立模式下运行，如下所示：

bin/connect-standalone.sh config/connect-standalone.properties connector1.properties connector2.properties ...

我的问题是连接器可以在运行时加载自己的名称吗？

提前谢谢。

Answer 1

是的，您可以在运行时获取连接器的名称。

当连接器启动时，所有属性都将传递给Connector::start(Map<String, String> props) 。连接器可以读取这些属性，验证它们，保存并在以后传递给Task。这取决于连接器实现是否使用它。

连接器名称属性为 name 。