How to configure KafkaConnector

[brgsousa]

How can I define a KafkaConnector that could hide some parameters like "connection.password". Can I use kubernetes secrets?

  "config": {
    "connector.class": "io.debezium.connector.jdbc.JdbcSinkConnector",     
    "tasks.max": "1",	     
    "connection.url": "jdbc:sqlserver://<ip-address>:<port>;databaseName=KAFKA;encrypt=false",     
    "connection.username": "user",     
    "connection.password": "PASSWORDHERE",
    "insert.mode": "upsert",
    "delete.enabled": "true",
    "primary.key.mode": "record_key",
    "schema.evolution": "basic",
    "topics": "cdc-global.kafka.correio.tPais",
    "errors.tolerance": "all",     
    "quote.identifiers": true,     
    "transforms": "RemoveString",     
    "transforms.RemoveString.type": "org.apache.kafka.connect.transforms.RegexRouter",
    "transforms.RemoveString.regex": "cdc-global\\.kafka\\.correio\\.(.*)",
    "transforms.RemoveString.replacement": "$1", 
    "table.name.normalize": false, 
    "table.name.format": "kafka.externoglobalcorreio.${topic}",
    "connection.pool.timeout": "150",
    "hibernate.c3p0.idle_test_period": "30"    
  }

[scholzj]

You can use the configuration providers together with Kubernetes Secrets for example. Please check the docs.

[brgsousa]

Link to doc: https://strimzi.io/blog/2021/07/22/using-kubernetes-config-provider-to-load-data-from-secrets-and-config-maps/