Tag: CONFLUENT-KAFKA-DOTNET
¿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
Estoy intentando publicar un mensaje en un tema de Kafka desde el centro de control para realizar pruebas iniciales. Necesito incluir un encabezado en el mensaje. ¿Se puede hacer esto desde el centro de control? Imagen: enlace a la imagen
Me pregunto cómo es posible integrar el paquete de ConfluentKafka en un proyecto de .net standard 2.1 en .net core 2.1. En la descripción en nuget.org, parece que puede ejecutarse cuando el objetivo del proyecto es hasta .net standard 2.0 / .net core 2.1. Prácticamente lo he visto en uso . . . Read more
Mi aplicación debe consumir mensajes de un tema de Kafka en un momento específico o cuando se active. Entonces, cuando mi consumidor está inactivo sin consumir mensajes, se elimina del grupo de consumidores. Se excedió el intervalo máximo de sondeo de la aplicación (300000ms) en 277ms (ajuste max.poll.interval.ms para el . . . 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