Kafka 连接器可以加载自己的名称吗？答案

【问题标题】：Can a Kafka Connector load its own name?Kafka 连接器可以加载自己的名称吗？
【发布时间】：2019-08-13 13:12:10
【问题描述】：

根据 Kafka 文档

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

大多数配置都依赖于连接器，因此无法概述这里。但是，有一些常见的选项：
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 ...

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

提前致谢。

【问题讨论】：

标签： apache-kafka apache-kafka-connect

【解决方案1】：

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

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

连接器名称属性为name。

【讨论】：

感谢它们是通过连接器任务的“public void start(Map props)”方法的属性参数加载的。