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 <[email protected]> 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
