Я использую источник JDBC и соединитель приемника kafka-connect-mongodb для потоковой передачи данных из JDBC в MongoDB.
Пока что я могу получить все вставки и обновления в виде нового документа (да, обновления вставляются как новые документы) на стороне MongoDB с после конфигов ;
репо: https://github.com/hpgrahsl/kafka-connect-mongodb
конфиги:
"mongodb.document.id.strategy":"at.grahsl.kafka.connect.mongodb.processor.id.strategy.BsonOidStrategy",
"mongodb.post.processor.chain":"at.grahsl.kafka.connect.mongodb.processor.DocumentIdAdder",
"mongodb.delete.on.null.values":false,
"mongodb.writemodel.strategy":"at.grahsl.kafka.connect.mongodb.writemodel.strategy.ReplaceOneDefaultStrategy"
Я бы хотел добиться сейчас для обновления документав случае обновления строки на стороне Oracle .
При конфигурации ниже я могу получить только последнюю вставку или обновление, выполненное на стороне Oracle, в коллекцию MongoDB в виде одного документа.Я имею в виду, что я обнаружил в MongoDB коллекцию с одним документом, который является последней операцией.
"mongodb.document.id.strategy":"at.grahsl.kafka.connect.mongodb.processor.id.strategy.PartialValueStrategy",
"mongodb.key.projection.list": "name,surname",
"mongodb.key.projection.type":"whitelist",
"mongodb.post.processor.chain":"at.grahsl.kafka.connect.mongodb.processor.DocumentIdAdder",
"mongodb.writemodel.strategy":"at.grahsl.kafka.connect.mongodb.writemodel.strategy.ReplaceOneBusinessKeyStrategy"
Оцените любую помощь заранее.Большое спасибо, Сонер