Разъем Debezium Kafka mongodb - PullRequest
       36

Разъем Debezium Kafka mongodb

0 голосов
/ 28 февраля 2019

Есть ли способ указать коннектору кафки, какие действия на монго следует учитывать.На самом деле, я не хочу, чтобы kafka что-то делал, когда монго-документ был удален (нужно просто обновить и вставить новый документ).
Спасибо

1 Ответ

0 голосов
/ 01 марта 2019

вы можете написать SMT (https://cwiki.apache.org/confluence/display/KAFKA/KIP-66%3A+Single+Message+Transforms+for+Kafka+Connect), который может отфильтровывать нежелательные операции. Примером является удаление записи delete из этого SMT - https://github.com/debezium/debezium-examples/blob/master/outbox/event-routing-smt/src/main/java/io/debezium/examples/outbox/routingsmt/EventRouter.java#L44

...