Debezium mysql task failed

Kafka Connect Self-Managed Connectors
2

I found myself for debugging and fixed.

Fix: Adding the below entries in my connector

database.history.kafka.topic: xx,
database.history.kafka.bootstrap.servers: xxx,
database.history.consumer.security.protocol: SASL_SSL,
database.history.consumer.ssl.endpoint.identification.algorithm: https,
database.history.consumer.sasl.mechanism: PLAIN,
database.history.consumer.sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username=\xx\ password=\xx/vF+xx/x+x;,
database.history.producer.security.protocol: SASL_SSL,
database.history.producer.ssl.endpoint.identification.algorithm: https,
database.history.producer.sasl.mechanism: PLAIN,
database.history.producer.sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username=\632HZGOZTJVRTFNU\ password=\xx/vF+xx/x+x;,
2 Likes