Whe the streaming from SQL Server is stoppend and restarted it is possible that a CDC event delivered before the restart is resent by the SQL server. The connector should detect such situation and filter out the duplicates based on comitted LSN.