Overview
Puedes cambiar manualmente la posición en una partición de tema de Apache Kafka desde la que un grupo de consumidores procesa mensajes restableciendo el desplazamiento. Un restablecimiento generalmente mueve el desplazamiento a una posición anterior, como el inicio de un tema, para que el conector reprocese los mensajes desde ese punto en adelante. También puedes mover el desplazamiento a una posición posterior para omitir mensajes.
Restablecimiento del desplazamiento del conector de origen
El conector de origen de MongoDB Kafka proporciona una forma de restablecer los desplazamientos mediante el uso de offset.partition.name propiedad de configuración. Para obtener más información, consulte Restablecer desplazamientos almacenados.
Restablecimiento del desplazamiento del conector del fregadero
MongoDB no admite el restablecimiento de offsets para el conector de destino de Kafka de MongoDB. Sin embargo, puede restablecer los offsets del grupo de consumidores asociado a su conector de destino mediante la herramienta de grupos de consumidores de Apache Kafka.
Para aprender más, consulta el Herramienta del grupo de consumidores de Kafka página en la documentación de Confluent.
Considerations
Antes de restablecer los desplazamientos del conector de origen de MongoDB Kafka o del conector de destino de MongoDB Kafka, tenga en cuenta lo siguiente:
Restablecer los desplazamientos puede provocar inconsistencias o pérdida de datos, ya que los mensajes pueden omitirse o reprocesarse. Utilice este procedimiento con precaución.
Los comandos de este procedimiento solo se aplican a Apache Kafka, no a su implementación de MongoDB. Los pasos necesarios pueden variar según el proveedor y la configuración. Consulte la documentación de su proveedor de Kafka y confirme con él o con el administrador que este procedimiento es adecuado para su entorno.