mongo-kafka

mongo-kafka copied to clipboard

Also apply any automatic code style changes by the latest ktlint. KAFKA-421

rozza

KAFKA-428: Mark the copy complete in the source offset for the last copied document

1

This fixes an issue that was occurring when: 1. startup mode `COPY_EXISTING` is used 2. the copy has completed 3. but no new has been sent 4. then the kafka...

Calvinnix

…sk switched to change stream the isCopying flag tracks wether the connector task is copying collection data or tracking change stream. This flag needs to be persisted, so that if...

rahulbats