除了 Kafka-connect FileConfigProvider，我们还有像 LdapConfigProvider 这样的东西吗？

Posted 2023-03-25

【中文标题】除了 Kafka-connect FileConfigProvider，我们还有像 LdapConfigProvider 这样的东西吗？

【英文标题】：Apart from Kafka-connect FileConfigProvider, Do we have anything like LdapConfigProvider?

【发布时间】：2019-07-29 10:28:51

【问题描述】：

需要使用在 LDAP 中外部化的数据源详细信息为 Oracle DB 创建 kafka-connect JdbcSinkConnector。

以下是连接器详细信息 kafka-connect-jdbc/sink-quickstart-oracle.properties 其中连接详细信息如 connection.url、connection.username、 connection.password 等应该来自 LDAP。

    name=test-sink
    connector.class=io.confluent.connect.jdbc.JdbcSinkConnector
    tasks.max=1
    topics=orders
    connection.url= ???? #should be sourced from LDAP
    connection.username= ???? #should be sourced from LDAP
    connection.password= ???? #should be sourced from LDAP
    auto.create=true

【问题讨论】：

提供您的示例代码、您的操作方式以及遇到的错误。

【参考方案1】：

开箱即用，Kafka 不提供这样的功能或配置。

作为KIP-297 的一部分，您必须编写/找到您自己的ConfigProvider 实现，您可以从中进行LDAP 查找，并将构建的JAR 添加到您的Connect 工作人员的类路径中。

【讨论】：

此外，我想说这取决于您的数据库驱动程序来实现。用户名和密码配置是可选的。网址不是。如果可以将ldap信息编码到url中，那么驱动负责处理