Página inicial do Docs → Desenvolver aplicações → MongoDB Kafka Connector
Manipulador de captura de dados de alteração
Nesta página
Visão geral
Saiba como replicar seus eventos de alterar captura de dados (CDC) com um conector de pia MongoDB Kafka. CDC é uma arquitetura de software que converte alterações em um armazenamento de dados em um fluxo de eventos CDC. Um evento CDC é uma mensagem que contém uma representação reproduzível de uma alteração realizada em um datastore. A replicação de dados é o processo de aplicar as alterações contidas em eventos CDC de um armazenamento de dados em um armazenamento de dados diferente para que as alterações ocorram em ambos os armazenamentos de dados.
Use um manipulador CDC para replicar eventos CDC armazenados em um tópico do Apache Kafka no MongoDB. Um manipulador CDC é um programa que converte eventos CDC de um produtor de eventos CDC específico em operações de gravação do MongoDB.
Um produtor de eventos CDC é um aplicativo que gera eventos CDC. Os produtores de eventos CDC podem ser armazenamentos de dados ou aplicativos que observam armazenamentos de dados e geram eventos CDC correspondentes a alterações nos armazenamentos de dados.
Observação
Os change streams do MongoDB são um exemplo de arquitetura de CDC. Para saber mais sobre change streams, consulte o guia do MongoDB Kafka Connector sobre change streams.
Se você quiser ver um tutorial que demonstre como replicar dados, consulte o tutorial Replicar dados com um manipulador de captura de dados de alteração.
Importante
CDC e pós-processadores
Não é possível aplicar um pós-processador aos dados de eventos do CDC. Se você tentar especificar ambos, o conector registrará um aviso.
Especificar um controlador de CDC
Você pode especificar um manipulador CDC no conector da pia com a seguinte opção de configuração:
change.data.capture.handler=<cdc handler class>
Para saber mais, consulte alterar opções de configuração de captura de dados.
Manipuladores de CDC disponíveis
O conector de pia fornece manipuladores CDC para os seguintes produtores de eventos CDC:
MongoDB
Clique nas seguintes abas para saber como configurar os manipuladores de CDC para os produtores de eventos anteriores:
Crie seu próprio manipulador de CDC
Se nenhum dos manipuladores de CDC pré-construídos se adequar ao seu caso de uso, você pode criar o seu. Seu manipulador de CDC personalizado é uma classe Java que implementa a interface do CdcHandler.
Para saber mais, consulte o código fonte para a interface do CdcHandler.
Para exibir exemplos de implementações de manipuladores CDC, consulte o código-fonte dos manipuladores CDC precriados.
Como usar seu manipulador de CDC
Para configurar o conector do coletor para usar o manipulador CDC personalizado, você deve executar as seguintes ações:
Compile sua classe do manipulador CDC customizada em um arquivo JAR.
Adicione o JAR compilado ao caminho de classe/plugin para seus trabalhadores do Kafka. Para obter mais informações sobre caminhos de plug-in, consulte a documentação do Confluent.
Observação
O Kafka Connect carrega plugins isoladamente. Quando você implanta uma estratégia de gravação personalizada, o JAR do conector e o JAR do manipulador CDC devem estar no mesmo caminho. Seus caminhos devem ser semelhantes ao seguinte:
<plugin.path>/mongo-kafka-connect/mongo-kafka-connect-all.jar<plugin.path>/mongo-kafka-connect/custom-CDC-handler.jarPara saber mais sobre plug-ins do Kafka Connect, consulte este guia do Confluent.
Especifique sua classe personalizada na definição de configuração do
change.data.capture.handler.
Para saber como compilar uma classe em um arquivo JAR, consulte este guia da Oracle .