我可以从连接器或任务访问 Kafka Connect Worker 配置吗?

Xia*_*ang 5 apache-kafka apache-kafka-connect

我正在开发一个自定义 Kafka 源连接器。我想访问工作配置,例如密钥转换器或值转换器或架构注册表 url 或 Zookeeper url 等,但我没有找到方法来做到这一点。任何想法?那可能吗?

更具体地说,在我的连接器和任务的实现中,我可以访问工作人员的配置吗?我检查过,我唯一能得到的是来自连接器实现的 ConnectorContext,并且它只有一种有用的方法来进行重新配置,但这不是我想要的。