This message was deleted.

What do the task logs say ?

interesting. @Didip Kerabat do you know if there was a major change preceding it? e.g. maybe an upgrade

Task logs didn’t say anything because it bombed earlier. As it turned out, the Kafka I am connecting to enforces authz via consumer group. After adding

group.id

in

consumerProperties

, it worked.

Nice. I am curious about how did it work. did you just set same group id (kafka-supervisor-xxx) in consumer properties?

yes, I just set the same

group.id

as what the Kafka team gave me.

I suppose that they also had to change some ACLs on their end.

Fresh cluster install.

I see similar issue "errorMsg": "org.apache.kafka.common.errors.GroupAuthorizationException: Not authorized to access group: kafka-su...

how we fixed it is setting the

group.id

in the supervisor spec.