Todos los productos
Search

Este producto

    ApsaraMQ for Kafka:Restablecer los offsets de consumidores

    Centro de documentos

    ApsaraMQ for Kafka:Restablecer los offsets de consumidores

    Última actualización: Oct 09, 2026

    Restablezca un offset de consumidor para volver a consumir mensajes desde una posición anterior o desde un offset de partición específico. También puede avanzar hasta la posición más reciente para omitir los mensajes acumulados.

    Requisitos previos

    Detenga todos los clientes consumidores. ApsaraMQ for Kafka no admite el restablecimiento de offsets para consumidores activos.

    Importante

    Después de detener un cliente consumidor, el broker lo considera desconectado solo cuando transcurre el periodo ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG (valor predeterminado: 10 000 ms).

    Contexto

    ApsaraMQ for Kafka admite los siguientes métodos de restablecimiento:

    • Iniciar el consumo desde el offset más reciente: restablece el offset a la posición más reciente y omite cualquier acumulación de mensajes.

    • Iniciar el consumo desde un momento específico: restablece el offset a una marca de tiempo pasada según el momento en que se almacenaron los mensajes. Siempre que los mensajes permanezcan dentro del periodo de retención de Kafka (valor predeterminado: 3 días), esta opción garantiza que se vuelvan a consumir todos los mensajes a partir de la marca de tiempo especificada sin omitir ninguno.

      Nota

      Antes de restablecer el offset, detenga todos los clientes consumidores y espere a que transcurra el periodo ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG (valor predeterminado: 10 000 ms). De este modo, el broker reconocerá a todos los consumidores como desconectados antes de que el restablecimiento surta efecto.

    • Restablecer los offsets de consumidores por partición: restablece los offsets únicamente de particiones específicas. Así se evita volver a consumir los mensajes que ya se procesaron correctamente en otras particiones.

    Nota

    Esta operación solo modifica el offset del consumidor y no elimina los mensajes acumulados.

    Procedimiento

    1. Inicie sesión en la consola de ApsaraMQ for Kafka.

    2. En la página Overview, seleccione una región en la sección Resource Distribution.

    3. En la página Instances, haga clic en el nombre de la instancia de destino.

    4. En el panel de navegación izquierdo, haga clic en Groups.

    5. En la página Groups, haga clic en el Group ID de destino.

    6. En la página Group Details, haga clic en Reset Consumer Offset.

    7. En el panel Reset Consumer Offset for Group, revise los Prerequisites y establezca la política de restablecimiento.

      1. Configure la opción Reset All Topics.

        • Haga clic en Yes para restablecer los offsets de consumidores de todos los topics.

        • Haga clic en No e introduzca el nombre del topic que desea restablecer en el cuadro de texto Topic.

      2. Configure el Reset Method.

        • Haga clic en Reset Consumer Offset to Latest Offset y luego en OK.

        • Haga clic en Reset Consumer Offset to Offset at Specified Point in Time. En el campo Point in Time, haga clic en el icono de calendario Calendar y seleccione la hora de inicio del consumo. Después, haga clic en OK.

        • Haga clic en Reset Consumer Offsets by Partition. En la fila de la partición de destino, introduzca el offset inicial en el cuadro de texto Consumer Offset y luego haga clic en OK.

    8. En el cuadro de diálogo Note, confirme la información y haga clic en OK.

    Preguntas frecuentes

    ¿El restablecimiento de offsets de consumidores resuelve los fallos de consumo parcial de un topic?

    Restablecer los offsets de consumidores ayuda a mitigar algunos casos de fallos de consumo parcial de un topic. Sin embargo, antes de continuar, compruebe si el problema se debe a reequilibrios frecuentes o a una asignación anómala de particiones.

    • Si ocurren reequilibrios frecuentes, verifique la versión del cliente de Kafka y ajuste los parámetros session.timeout.ms y max.poll.interval.ms con valores adecuados para su carga de trabajo de consumo.

    • Confirme que el grupo de consumidores se haya suscrito correctamente al topic de destino.

    Si se confirma que la causa raíz es una asignación anómala de particiones, el restablecimiento del offset permite que el grupo de consumidores vuelva a consumir los mensajes desde la posición correcta.

    ¿Puedo seguir consumiendo después de cambiar el ID del grupo de consumidores de Kafka?

    Sí. Después de cambiar el ID del grupo de consumidores, el nuevo grupo puede continuar con el consumo. No obstante, el offset inicial depende de si el nuevo grupo comienza por primera vez y del estado actual del topic. Antes de cambiar los ID de los grupos de consumidores, investigue la causa raíz de cualquier problema, como errores de red o tiempos de espera de heartbeat agotados. Esto evitará que el nuevo grupo enfrente situaciones similares.

    ¿Al eliminar un grupo de consumidores de Kafka también se eliminan los topics suscritos?

    No. Los grupos de consumidores y los topics son recursos independientes en ApsaraMQ for Kafka. Al eliminar un grupo de consumidores solo se quita dicho grupo junto con sus offsets. Los datos y la configuración de los topics suscritos no se ven afectados.

    Documentos relacionados