Migrar do Kafka Connect MongoDB

Use este guia para migrar seus Kafka sistemas do do Kafka Connect criado pela MongoDB comunidade coletor de connector ao conector oficial MongoDB Kafka Connector.

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 coleção que contenham o prefixo mongodb.collection pela chave equivalente naspropriedades do tópico de configuração do tópico Kafka do conector do coletor .

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:
- MongoSinkConfig
- MongoSinkTopicConfig

Atualizar subclasses de pós-processador

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

Voltar

Monitoramento

Solução de problemas