Visão geral
Você pode alterar manualmente a posição em uma partição de tópico do Apache Kafka da qual um grupo de consumidores processa mensagens redefinindo o deslocamento. Uma redefinição normalmente move o deslocamento para uma posição anterior, como o início de um tópico, de modo que o conector reprocesse mensagens desse ponto em diante. Você também pode mover o deslocamento para uma posição posterior para ignorar mensagens.
Redefinindo um deslocamento do Connector de origem
O conector de origem do MongoDB Kafka fornece uma maneira de redefinir deslocamentos usando a propriedade de configuração do offset.partition.name. Para aprender mais, consulte Redefinir deslocamentos armazenados.
Redefinindo um deslocamento do Connector do coletor
O MongoDB não oferece suporte à redefinição de deslocamentos para o conector de coletor do MongoDB Kafka. No entanto, você pode redefinir os deslocamentos do grupo de consumidores associado ao conector do coletor usando a ferramenta de grupo de consumidores do Apache Kafka.
To learn more, see the página da ferramenta de grupo de consumidores Kafka na documentação do Confluent.
Considerações
Antes de redefinir o conector de origem do MongoDB Kafka ou os offsets do conector de coletor do MongoDB Kafka, considere o seguinte:
A redefinição de offsets pode resultar em inconsistência de dados ou perda de dados, pois as mensagens podem ser ignoradas ou reprocessadas. Use este procedimento com cuidado.
Os comandos neste procedimento operam apenas no Apache Kafka, não na sua implantação do MongoDB. As etapas necessárias podem variar entre provedores e configurações. Revise a documentação do fornecedor do Kafka e confirme com o fornecedor ou administrador se este procedimento é apropriado para o seu ambiente.