setup MKS ( managed kafka ) consumer for Quarkus #41088
Replies: 3 comments 5 replies
-
/cc @alesj (kafka), @cescoffier (kafka), @ozangunalp (kafka) |
Beta Was this translation helpful? Give feedback.
-
What's the exception you are seeing? You just need to configure the Kafka client, so it should be vaguely similar to spring boot. |
Beta Was this translation helpful? Give feedback.
-
Ok, I was at last able to reproduce your error. You need to configure |
Beta Was this translation helpful? Give feedback.
-
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 io.quarkus quarkus-messaging-kafka
This is my properties file
quarkus.http.port=8094
mp.messaging.connector.smallrye-kafka.group.id=listeners-1
kafka.bootstrap.servers = ${KAFKA_SERVER_URL}
kafka.security.protocol = SASL_SSL
kafka.sasl.mechanism = AWS_MSK_IAM
kafka.sasl.jaas.config = software.amazon.msk.auth.iam.IAMLoginModule required;
kafka.sasl.login.callback.handler.class=software.amazon.msk.auth.iam.IAMClientCallbackHandler
mp.messaging.connector.smallrye-kafka.key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
mp.messaging.connector.smallrye-kafka.key.serializer=org.apache.kafka.common.serialization.StringSerializer
mp.messaging.incoming.payments-insights-topic.topic=topic1-${ENVIRONMENT:master}
aws.accessKeyId=<>
aws.secretAccessKey=<>
Beta Was this translation helpful? Give feedback.
All reactions