根据Kafka的文件
连接器配置是简单的键值Map。对于独立模式，这些在属性文件中定义，并通过命令行传递给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 ...我的问题是连接器能否在运行时加载自己的名称？
提前谢谢。
1条答案
按热度按时间qco9c6ql1#
是的，您可以在运行时获取连接器的名称。
连接器启动时，所有属性都传递给
Connector::start(Map<String, String> props). 连接器可以读取这些属性，验证它们，保存并稍后传递给Task. 这取决于他是否使用连接器实现。连接器名称属性为
name.