Connect Docker Kafka Connect to Confluent Cloud

Kafka Connect Self-Managed Connectors
6

I’m reaching, but the error is coming from the Kafka admin client (instantiated here, configured here). Based on the config code, it’ll use any properties prefixed with kafka.internal.client. (and remove the prefix), so try adding the following connector properties:

    "kafka.internal.client.security.protocol": "SASL_SSL",
    "kafka.internal.client.sasl.mechanism": "PLAIN",
    "kafka.internal.client.sasl.jaas.config": "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"<API KEY>\" password=\"<SECRET>\";",

If that doesn’t help, you might try filing a DBZ JIRA in case there’s a connector-specific issue we are missing.