Spring Boot AWS MSK Configuration

Question

要使用Kafka中的消息，我在本地使用以下配置。它运行良好。

spring.kafka.bootstrap-servers: localhost:9092
spring.kafka.consumer.key-deserializer: org.apache.kafka.common.serialization.IntegerDeserializer
spring.kafka.consumer.value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.group-id: order-events
spring.kafka.admin.properties.bootstrap.servers: localhost:9092

在DEV，SITKubernates集群中，我们使用的是AmazonMSK。以下详细信息已共享。

主机：z3.kafka-central-1.amazonaws.com:9096，z1.kafka-Centrral-1.amazonaws.com：9096，z2.kafka/central-1.amazonaws.com：9096

配置：3个分区，3个副本，3个代理，3个不同的AZ，SASL/SCRAM身份验证，保留。ms=604800000，max.message.bytes=2097164

VPC Id:VPC-123sdfsdf234

AWS账户123456789

CIDR10.20.1.1/24

用户名用户msk kafka用户

密码XXXXXXXX

属性是什么，我应该在spring应用程序属性文件中配置。

Answer 1

您的MSK VPC CIDR10.20.1.1/24是私有的。

确保您用于连接MSK的Dev/SIT环境位于同一VPCvpc-123sdfsdf234中。如果它在同一个VPC内，请检查MSK安全组，以确保您的CIDR范围10.20.1.1/24已被列入所需端口的白名单。

否则，使用公共IP创建MSK。