setup MKS ( managed kafka ) consumer for Quarkus

Question

previusly i am using self hosted kafka recestly I have moved to mks and I'm facing issue to setup I am authentication for my quarkus application I'm able to make it work on python an springboot can I get some reference on the application.properties how can I setup it

I'm using <dependency> <groupId>io.quarkus</groupId> <artifactId>quarkus-messaging-kafka</artifactId> </dependency>

I'm using 
    
      io.quarkus
      quarkus-messaging-kafka

Ed Berezitsky · Answer

Please check [the documentation](https://docs.aws.amazon.com/msk/latest/developerguide/iam-access-control.html).

Specifically, for Java you would need to include [JARs with auth classes](https://github.com/aws/aws-msk-iam-auth/releases/tag/v2.1.0), and then add following properties to your kafka client/app:

```
security.protocol=SASL_SSL
sasl.mechanism=AWS_MSK_IAM
sasl.jaas.config=software.amazon.msk.auth.iam.IAMLoginModule required;
sasl.client.callback.handler.class=software.amazon.msk.auth.iam.IAMClientCallbackHandler
```

Make sure the IAM role you will be using to run the app has policies for accessing MSK cluster.

Same documentation include all you need to know for Python apps as well. if you face specific issue, please attach more details, like what you are trying to run, what errors/exceptions you are facing, etc.

setup MKS ( managed kafka ) consumer for Quarkus

Add your answer

Relevant content