es.davy.ai

Preguntas y respuestas de programación confiables

¿Tienes una pregunta?

Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.

Configuración de Spring Boot para AWS MSK

13 Jul, 2023 Programación

Para consumir mensajes de Kafka, estoy utilizando la siguiente configuración en mi entorno local. Funciona correctamente.

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

En el clúster DEV y SIT de Kubernates, estamos utilizando Amazon MSK. Se han compartido los siguientes detalles:

Host: z3.kafka-central-1.amazonaws.com:9096,z1.kafka-central-1.amazonaws.com:9096,z2.kafka-central-1.amazonaws.com:9096

Configuración: 3 particiones, 3 réplicas, 3 brokers, 3 AZs diferentes, autenticación SASL/SCRAM, retention.ms=604800000, max.message.bytes=2097164

VPC Id: vpc-123sdfsdf234

Cuenta de AWS: 123456789

CIDR: 10.20.1.1/24

Nombre de usuario: user-msk-kafka-user

Contraseña: XXXXXXXX

¿Cuáles son las propiedades que debo configurar en el archivo de propiedades de la aplicación Spring?

Tags:  , , ,

Answer

  1. Avatar for davy.ai
    davy.ai 

    spring.kafka.bootstrap-servers: z3.kafka-central-1.amazonaws.com:9096,z1.kafka-central-1.amazonaws.com:9096,z2.kafka-central-1.amazonaws.com:9096
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: z3.kafka-central-1.amazonaws.com:9096,z1.kafka-central-1.amazonaws.com:9096,z2.kafka-central-1.amazonaws.com:9096
spring.kafka.properties.security.protocol: SASL_SSL
spring.kafka.properties.sasl.mechanism: SCRAM-SHA-512
spring.kafka.properties.sasl.jaas.config: org.apache.kafka.common.security.scram.ScramLoginModule required username="usuario-msk-kafka" password="XXXXXXXX";
spring.kafka.listener.ack-mode: record

    Nota: Reemplaza el nombre de usuario y la contraseña con las credenciales reales proporcionadas. Además, ajusta otras configuraciones según tus requisitos.

Comments are closed.