使用IAM的AWS MSK Spring Boot应用程序示例

Question

我想创建一个Spring Boot应用程序，该应用程序使用IAM连接到AWS MSK，并生成和消耗事件。我在互联网上查看了该事件，但找不到任何好的资源

注意：我已经在AWS EKS.上部署了我的演示应用hello world应用程序

Answer 1

您可以在文档中看到对client.properties文件的引用。

ssl.truststore.location=<PATH_TO_TRUST_STORE_FILE>
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

Spring Kafka在spring.kafka.properties下使用相同的属性