Re: AdminClient fails to authenticate to Azure Eventhub for MirrorMaker2

This seems to be related to the strimzi side. I will continue investigating
with stimzi .

Thanks.

On Sun, Sep 27, 2020 at 3:00 PM Yu Watanabe <yu.w.tennis@gmail.com> wrote:

> 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
>
>


--
Yu Watanabe

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