Xia*_*ang 5 apache-kafka apache-kafka-connect
我正在开发一个自定义 Kafka 源连接器。我想访问工作配置,例如密钥转换器或值转换器或架构注册表 url 或 Zookeeper url 等,但我没有找到方法来做到这一点。任何想法?那可能吗?
更具体地说,在我的连接器和任务的实现中,我可以访问工作人员的配置吗?我检查过,我唯一能得到的是来自连接器实现的 ConnectorContext,并且它只有一种有用的方法来进行重新配置,但这不是我想要的。
| 归档时间: |
|
| 查看次数: |
267 次 |
| 最近记录: |