Para agentes de IA: um índice de documentação está disponível em https://www.mongodb.com/pt-br/docs/llms.txt — as versões de markdown de todas as páginas estão disponíveis anexando .md a qualquer caminho de URL.
Menu Docs
Página inicial do Docs
/
Ferramentas
/
Conector Kafka
Página inicial do Docs
/
Ferramentas
/
Conector Kafka
Página inicial do Docs
/
Ferramentas
/
Conector Kafka

Migrar do Kafka Connect MongoDB

Use este guia para migrar suas implantações do Kafka do conector de sink do MongoDB do Kafka Connect criado pela comunidade para o Conector Kafka oficial do MongoDB.

As seções a seguir listam as alterações que você deve fazer nas definições de configuração do connector de coletor do Kafka Connect e nas classes personalizadas para fazer a transição para o connector de coletor do MongoDB Kafka.

Observação

O Atlas Stream Processing fornece ferramentas nativas do MongoDB para processar continuamente dados de streaming, validar esquemas e materializar visualizações em coleções de banco de dados do Atlas ou tópicos Apache Kafka.

Para saber mais sobre o Atlas Stream Processing, consulte Atlas Stream Processing.

Atualizar configurações

Faça as seguintes alterações nas definições de configuração do sistema do Kafka Connect antes de usá-las com o sistema do Kafka Connector MongoDB:

  • Substitua os valores que incluem o pacote at.grahsl.kafka.connect.mongodb pelo pacote com.mongodb.kafka.connect.

  • Substitua a configuração connector.class pela classe de connector do sink MongoDB Kafka.

    connector.class=com.mongodb.kafka.connect.MongoSinkConnector

  • Remova o prefixo mongodb. dos seus nomes de propriedade do Kafka Connect. Por exemplo, altere mongodb.connection.uri para connection.uri.

  • Remova a configuração document.id.strategies se ela existir. Se o valor dessa configuração fizer referência a estratégias personalizadas, mova-as para a configuração document.id.strategy . Leia a seção Atualizar classes personalizadas para descobrir quais alterações você deve fazer em suas classes personalizadas.

  • Substitua todos os nomes de propriedade que você usa para especificar substituições por tópico ou collection que contenham o prefixo mongodb.collection pela chave equivalente nas propriedade do tópico de configuração do tópico do Kafka do connector de pia.

Atualizar classes personalizadas

Se você usar alguma classe personalizada na implantação do connector de coletor do Kafka, faça as seguintes alterações nelas antes de adicioná-las à implantação do MongoDB Kafka Connector:

  • Substitua as importações que incluem at.grahsl.kafka.connect.mongodb por com.mongodb.kafka.connect.

  • Substitua as referências à classe MongoDbSinkConnector pela classe MongoSinkConnector .

  • Atualize as classes de estratégia do connector de coletor personalizado para implementar a interface com.mongodb.kafka.connect.sink.processor.id.strategy.IdStrategy .

  • Atualize as referências para a classe MongoDbSinkConnectorConfig . No MongoDB Kafka Connector, a lógica dessa classe é feita a divisão nas seguintes classes:

Atualizar subclasses de pós-processador

Se você tiver classes que subclassificam um pós-processador em seu sistema do conector Kafka Connect, atualize os métodos que substituem os na classe Kafka Connect PostProcessor para corresponder às assinaturas de método da classe PostProcessor do MongoDB Kafka Connector.

Voltar

Monitoramento

Próximo

Compare o Conector Kafka e o Atlas Stream Processing