首页 > 解决方案 > 使用 TLS 和 Spring-kafka 的 AWS MSK 问题

问题描述

任何人使用 AWS MSK 和 TLS,使用 Spring-kafka,下面是我们应用程序的详细信息,使用下面的配置,应用程序无法正常工作

  1. 我们已经在 Fargate 上部署了我们的消费者/生产者
  2. kafka-client 版本为 2.1.1
  3. 以下是用作消费者和生产者一部分的配置值

     spring.kafka.ssl.protocol=ssl
     spring.kafka.ssl.trust-store-location=file:/home/ec2-user/truststore.jks
     spring.kafka.properties.security.protocol=ssl
     spring.kafka.bootstrap-servers:"xxxx:9094,xxxx:9094,xxxx:9094"
    

当我们部署应用程序时,Fargate 实例不断重启,抛出内存不足异常,但我们的任务定义是 4cpu 和 12 GB RAM,通常应用程序在 2cpu 和 4 GB RAM 下运行良好。此外,应用程序在早期使用自托管 Kafka 时运行良好。

标签: apache-kafkaspring-kafkaaws-fargateaws-mskamazon-msk

解决方案


推荐阅读