Getting Failed to configure SaslClientAuthenticator in mirrormake source connector

[Sameer Modak]

Hello Team,

I m trying to replicate data from old kafka cluster with confluent510 to msk 3.7.x.

We created connect distributed cluster and trying to replication data using mm2 connectors which are source connector, heartbeat connector and checkpoint connector.

{
    "name": "mm2-HeartbeatConnector-1",
    "config": {
        "connector.class": "org.apache.kafka.connect.mirror.MirrorHeartbeatConnector",
        "source.cluster.alias": "dckafka",
        "key.converter": "org.apache.kafka.connect.converters.ByteArrayConverter",
        "value.converter": "org.apache.kafka.connect.converters.ByteArrayConverter",
        "refresh.groups.interval.seconds": "60",
        "refresh.topics.interval.seconds": "60",
        "target.cluster.alias": "testmsk",
        "target.cluster.bootstrap.servers": "b-1.testmsk.amazonaws.com:9096,b-2.testmsk.amazonaws.com:9096,b-3.testmsktestmsk.amazonaws.com:9096",
        "producer.linger.ms": "500",
        "heartbeats.topic.replication.factor": "3",
        "target.cluster.sasl.jaas.config": "org.apache.kafka.common.security.scram.ScramLoginModule required username=\"kafka_admin\" password=\"test123\";",
        "tasks.max": "2",
        "refresh.groups.enabled": "true",
        "refresh.topics.enabled": "true",
        "producer.retry.backoff.ms": "1000",
        "target.cluster.security.protocol": "SASL_SSL",
        "clusters": "dckafka,testmsk",
        "emit.checkpoints.enabled": "true",
        "target.cluster.sasl.mechanism": "SCRAM-SHA-512",
"source.cluster.security.protocol": "PLAINTEXT",
        "source.cluster.bootstrap.servers": "x.x.x.9:9092,x.x.x.7:9092,x.x.x.8:9092"
    }
}

=========error we are getting is below ,

Caused by: org.apache.kafka.common.KafkaException: org.apache.kafka.common.errors.SaslAuthenticationException: Failed to configure SaslClientAuthenticator

        at org.apache.kafka.common.network.SaslChannelBuilder.buildChannel(SaslChannelBuilder.java:239)

        at org.apache.kafka.common.network.Selector.buildAndAttachKafkaChannel(Selector.java:338)

        ... 8 more

Caused by: org.apache.kafka.common.errors.SaslAuthenticationException: Failed to configure SaslClientAuthenticator

Caused by: org.apache.kafka.common.errors.SaslAuthenticationException: Failed to create SaslClient with mechanism SASL_SSL