Reputation: 3
Need to create kafka-connect JdbcSinkConnector for Oracle DB using Datasource details which are externalized in LDAP.
Following are the connector details kafka-connect-jdbc/sink-quickstart-oracle.properties where connection details like connection.url, connection.username, connection.password etc. should come from 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
Upvotes: 0
Views: 166
Reputation: 191874
Out of the box, Kafka does not provide such a feature or configuration.
As part of KIP-297, you would have to write/find your own implementation of a ConfigProvider
from which you could do an LDAP lookup, and add that built JAR to your Connect workers' classpaths.
Upvotes: 0