除了 Kafka-connect FileConfigProvider，我们还有类似 LdapConfigProvider 的东西吗？

Question

需要使用在 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

Answer 1

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

作为 KIP-297 的一部分，您必须 write/find 您自己的 ConfigProvider 实现，您可以从中执行 LDAP 查找，并将构建的 JAR 添加到您的 Connect工人的阶级道路。