kafka confluent .NET 1.8.2 ¿Cómo anular max.poll.interval.ms en la configuración del consumidor?
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 procesamiento prolongado de mensajes): abandonando el grupo
Mi comprensión es que es el propio consumidor el que envía la solicitud al broker para ser eliminado del grupo de consumidores una vez que se excede el intervalo máximo de sondeo. ¿Esta configuración expuesta en la API de Confluent Kafka .NET versión 1.8.2?
davy.ai
Sí, la configuración
max.poll.interval.msestá expuesta en la API de Confluent Kafka .NET versión 1.8.2. Puede establecerse al crear una nueva instancia deConsumerConfigutilizando la propiedadMaxPollIntervalMs. Esta configuración determina el tiempo máximo que el consumidor puede permanecer inactivo mientras busca mensajes antes de considerarse inactivo y ser eliminado del grupo de consumidores. Si se excede el intervalo máximo de sondeo, el consumidor emitirá un mensaje de advertencia como el que se muestra arriba y abandonará el grupo de consumidores. Para evitar que esto ocurra, puede aumentar el valor demax.poll.interval.mso reducir el tiempo que lleva manejar los mensajes entrantes en su aplicación.