Overview
Puedes cambiar manualmente la posición en una partición del tema Apache Kafka desde la que un grupo de consumidores procesa mensajes restableciendo el offset. Un reinicio normalmente mueve el offset a una posición anterior, como al principio de un tema, de modo que el conector reprocesa los mensajes desde ese punto en adelante. También puede mover el desplazamiento a una posición posterior para saltar mensajes.
Restablecimiento de un desplazamiento del Connector de origen
El conector de origen MongoDB Kafka proporciona una forma de restablecer los desplazamientos mediante el offset.partition.name propiedad de configuración. Para obtener más información, consulte Restablecer desplazamientos almacenados.
Restableciendo el desplazamiento del Connector Sink
MongoDB no admite el restablecimiento de desplazamientos para el conector MongoDB Kafka sink. Sin embargo, puedes restablecer los desplazamientos del grupo de consumidores asociado con tu conector de sink utilizando la herramienta de grupos de consumidores de Apache Kafka.
Para aprender más, consulta el Herramienta de grupos de consumidores de Kafka página en la documentación de Confluent.
Considerations
Antes de restablecer los valores de desplazamiento de tu conector origen de MongoDB Kafka o del conector sumidero de MongoDB Kafka, ten en cuenta lo siguiente:
Restablecer desplazamientos puede dar lugar a incoherencias de datos o pérdida de datos, ya que los mensajes pueden omitirse o volver a procesarse. Siga este procedimiento con precaución.
Los comandos de este procedimiento solo operan en Apache Kafka, no en la implementación de MongoDB. Los pasos requeridos pueden variar entre proveedores y configuraciones. Revisa la documentación de tu proveedor de Kafka y confirma con tu proveedor o administrador que este procedimiento sea apropiado para tu entorno.