@karthik_p

It seems I made some progress with the approach mentioned. But I get an error:

Caused by: kafkashaded.org.apache.kafka.common.errors.SaslAuthenticationException: [dabd4181-e46b-4d41-8e01-87b4a0ec9f5a]: Access denied

I am wondering what else I am missing!