MirrorMaker2 to Confluent Cloud: ConnectException: Failed to connect to and describe Kafka cluster

Confluent Cloud
1

Team,
We would like to replicate data from MirrorMake2 to Confluent Cloud.
Our setting:

        bootstrapServers: "pkc-epwny.eastus.azure.confluent.cloud:9092"
        config:
         sasl.mechanism: PLAIN
         security.protocol: SASL_PLAINTEXT
         sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username='***' password='***';

Issue:

2022-02-28 19:00:13,568 ERROR Stopping due to error (org.apache.kafka.connect.cli.ConnectDistributed) [main]
org.apache.kafka.connect.errors.ConnectException: Failed to connect to and describe Kafka cluster. Check worker's broker connection and security properties.
at org.apache.kafka.connect.util.ConnectUtils.lookupKafkaClusterId(ConnectUtils.java:70)
at org.apache.kafka.connect.util.ConnectUtils.lookupKafkaClusterId(ConnectUtils.java:51)
at org.apache.kafka.connect.cli.ConnectDistributed.startConnect(ConnectDistributed.java:97)
at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:80)
Caused by: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Call(callName=listNodes, deadlineMs=1646074813542, tries=1, nextAllowedTryMs=1646074813643) timed out at 1646074813543 after 1 attempt(s )

The issue happens when connecting MM2 with Confluent (SaaS).
We would appreciate any feedback

2

hi @cassiofreire

welcome to the forum :slight_smile:

how did you configure you username and password?

there is also a nice tutorial out there by @vdesabou
might be worth to follow this guide

best,
michael

3

It uses SASL_SSL as the security.protocol. How can I configure the Confluent cloud to use SASL_PLAINTEXT.