Menu Docs

Página inicial do Docs → Desenvolver aplicações → MongoDB Kafka Connector

Migrar do Kafka Connect MongoDB

Use este guia para migrar suas implantações do Kafka do Kafka Connect MongoDB criado pela comunidade conector de coletor ao conector oficial Kafka 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.

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 do Kafka Connect PostProcessor para corresponder às assinaturas de método da classe PostProcessor do conector Kafka MongoDB.

← Monitoramento
Solução de problemas →