Tag: KAFKA-CONSUMER-API
¿Cómo puedo escribir mensajes en el productor de una vez y leer 1 mensaje por minuto con el consumidor? Propiedades de configuración que puedo usar: imagen de configuración de propiedades nota: tenga en cuenta “max.poll.records” que no puedo usar el método Mi clase de consumidor: var settings = ConfigurationManager.KafkaSettings.Topics[Topics.FaturaKaydetViaTp]; LogManager.Logger.Debug(“Iniciando . . . Read more
Tengo un caso de uso en el que tengo que probar el punto de saturación de mi clúster de Kafka (de 3 nodos) con un alto número de grupos de consumidores. (Para encontrar el punto de saturación para nuestro caso de uso de producción) Confirmación (“ack”) del productor: todo. He . . . Read more
Necesito ayuda para encontrar la mejor solución de diseño para crear consumidores de Kafka. Tendré múltiples temas y estos pueden ser como grupos, por ejemplo, 10 temas que se utilizan para enviar correos electrónicos (se elige una cantidad de 10 porque recibiré más tráfico de clientes y quiero dedicar un . . . Read more
Tengo una aplicación de Kafka Streams versión 2.5.1 (kafka spring) y conectores CDC que continuamente producen datos en el tema. Tengo un total de 14 temas que se unen a los datos como se muestra a continuación y producen el resultado en el tema final. ktable1.join(ktable2).leftJoin(ktable3).leftJoin(ktable4).to(finalTopic) Cuando aumenta la carga . . . Read more
Me gustaría crear un servicio de registro que escuche todos los temas de Kafka en el clúster y los almacene en la base de datos. ¿Cómo puedo decirle a Kafka que me gustaría escuchar todos los temas? Mi enfoque simple con el comodín @EventPattern(‘*’) no funcionó… ¿Alguna idea de cómo . . . Read more