AdminClient fails to authenticate to Azure Eventhub for MirrorMaker2

Hello .

I use MirrorMaker2 on strimzi to mirror data from Azure Eventhub to kafka
cluster.
However, MirrorMaker2 fails to authenticate to Azure Eventhub with
following error.
This happens when consuming logs from eventhub not when mirroring to
eventhub..

I use strimzi 0.17.0 and kafka 2.4.0 for my environment.

---------------------------------------------------------------------------------------------
2020-09-27 02:08:16,019 INFO [AdminClient clientId=adminclient-21533]
Failed authentication with
migration-kafka-topics-connect.servicebus.windows.net/40.79.186.34 (Invalid
SASL mechanism response, server may be expecting a different protocol)
(org.apache.kafka.common.network.Selector) [kafka-admin-client-thread |
adminclient-21533]
2020-09-27 02:08:16,019 WARN [AdminClient clientId=adminclient-21533]
Metadata update failed due to authentication error
(org.apache.kafka.clients.admin.internals.AdminMetadataManager)
[kafka-admin-client-thread | adminclient-21533]
org.apache.kafka.common.errors.IllegalSaslStateException: Invalid SASL
mechanism response, server may be expecting a different protocol
Caused by: org.apache.kafka.common.protocol.types.SchemaException: Error
reading field 'auth_bytes': Bytes size -1 cannot be negative
at
org.apache.kafka.common.protocol.types.Schema.read(Schema.java:110)
at
org.apache.kafka.common.protocol.ApiKeys.parseResponse(ApiKeys.java:314)
at
org.apache.kafka.clients.NetworkClient.parseStructMaybeUpdateThrottleTimeMetrics(NetworkClient.java:712)
at
org.apache.kafka.clients.NetworkClient.parseResponse(NetworkClient.java:702)
at
org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.receiveKafkaResponse(SaslClientAuthenticator.java:514)
at
org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.receiveToken(SaslClientAuthenticator.java:448)
at
org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.authenticate(SaslClientAuthenticator.java:262)
at
org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:173)
at
org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:547)
at org.apache.kafka.common.network.Selector.poll(Selector.java:483)
at
org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:540)
at
org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1196)
at java.lang.Thread.run(Thread.java:748)
2020-09-27 02:08:16,019 ERROR [AdminClient clientId=adminclient-21533]
Connection to node -1 (
migration-kafka-topics-connect.servicebus.windows.net/40.79.186.34:9093)
failed authentication due to: Invalid SASL mechanism response, server may
be expecting a different protocol (org.apache.kafka.clients.NetworkClient)
[kafka-admin-client-thread | adminclient-21533]
---------------------------------------------------------------------------------------------

I am trying to diagnose the error but bit having difficulty.
Would there be anyone who had faced similar issue ?
If so , I appreciate if I could get advice to overcome the error.

Best Regards,
Yu Watanabe

--
Yu Watanabe

linkedin: www.linkedin.com/in/yuwatanabe1/
twitter: twitter.com/yuwtennis