The Kafka connector guarantees it will eventually deliver the latest version of each document; it does not guarantee it will deliver a full history of every change. If your use case requires capturing every change to a document, you might want to adopt one of the strategies detailed by Jon in your related thread: Is there any bound to Mutation deduping - #2 by jon.strabala
Thanks,
David