MongoDB工具 >MongoDB Kafka连接器 > 从Kafka Connect迁移
请按照本指南中的步骤将Kafka部署从Kafka Connect迁移 到 官方的MongoDB Kafka连接器。
at.grahsl.kafka.connect.mongodb
有com.mongodb.kafka.connect
。MongoDbSinkConnector
与MongoSinkConnector
作为价值connector.class
的关键。mongodb.
从所有配置属性键名称中删除“ ”前缀。document.id.strategies
密钥(如果存在)。如果此字段的值包含对任何自定义策略的引用,请将它们移至该
document.id.strategy
字段并阅读“ 更新自定义类”
部分,以获取对类的其他必需更改。mongodb.collection
在“ 主题特定的配置设置”中,用等价的键替换用于指定每个主题和集合替代的所有键,这些键包含前缀。如果您向Kafka Connect连接器添加了任何类或自定义逻辑,请将它们迁移到新的MongoDB Kafka连接器jar文件,并对它们进行以下更改:
at.grahsl.kafka.connect.mongodb
到
com.mongodb.kafka.connect
。MongoDbSinkConnector
类的
引用MongoSinkConnector
。com.mongodb.kafka.connect.sink.processor.id.strategy.IdStrategy
接口。MongoDbSinkConnectorConfig
已拆分为sink.MongoSinkConfig
和sink.MongoSinkTopicConfig
类的类的引用。PostProcessor
类中方法的所有具体方法,
以匹配MongoDB Kafka Connector PostProcessor
类的新方法签名。