mongo-kafka icon indicating copy to clipboard operation
mongo-kafka copied to clipboard

KAFKA-428 bug where copy existing is not persisted after it has finished copying

Open rahulbats opened this issue 1 year ago • 0 comments

…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 the connector restarts later it does no start copying the collection again. There was a if statement which persisted this flag only when iscopying is true which is wrong, as the iscopying flag needs to be persisted in offsets after it has turned false when it has finished copying

rahulbats avatar Oct 03 '24 00:10 rahulbats