Tag: KAFKA-CONSUMER-API
Estoy utilizando Java y Spring Boot y Kafka en mi aplicación. Quiero definir varios consumidores para el mismo tema dentro de Kafka. Ahora, estoy definiendo el ID de grupo dentro de mi archivo de propiedades de la aplicación: spring.cloud.stream.bindings.myFirstTopic.destination=my-first-topic spring.cloud.stream.bindings.myFirstTopic.group=my-first-consumer y en el método estoy utilizando la anotación: @StreamListener(MyFirstTopicBinding.MY_FIRST_TOPIC) public . . . Read more
Estamos notando un problema extraño con uno de nuestros temas de producción (6 particiones), donde nuestro consumidor (dotnet core, solo 1 instancia) solo puede leer de 3 particiones (0,1,3). Esto obviamente está afectando el comportamiento de la aplicación ya que el consumidor no está recibiendo los mensajes de las otras . . . Read more
Tengo un proyecto de automatización de pruebas. Estoy tratando de obtener los registros del consumidor de Kafka a partir del último registro con la configuración ConsumerConfig.AUTO_OFFSET_RESET_CONFIG = “latest”. Pero no funciona. Aquí hay un código en el que intento recuperar datos: for (int i = 0; i < 20; i++) . . . Read more
Puedo conectarme correctamente a un clúster de Kafka seguro con SSL utilizando las siguientes propiedades del cliente: security.protocol=SSL ssl.truststore.type=PKCS12 ssl.truststore.location=ca.p12 ssl.truststore.password=<redactado> ssl.keystore.type=PKCS12 ssl.keystore.location=user.p12 ssl.keystore.password=<redactado> Sin embargo, estoy desarrollando una aplicación Java que se ejecuta en un entorno en la nube gestionado, donde no tengo acceso al sistema de archivos. Por . . . Read more
Configuré la plataforma de Confluent en mi máquina local (mac), que se está ejecutando en “localhost:9021”. Ahora quiero crear una aplicación sencilla utilizando node.js, para poder publicar y consumir mensajes en la GUI de Confluent que se está ejecutando en “localhost:9021”. ¿Cómo puedo conectar la aplicación de node.js con esta . . . Read more