sivamu

Was able to reproduce this outside our connector source code by using this [sample application](https://github.com/Azure-Samples/azure-cosmos-java-sql-app-example). To do so, add the `_lsn` property with an integer value [here](https://github.com/Azure-Samples/azure-cosmos-java-sql-app-example/blob/main/src/main/java/com/azure/cosmos/workedappexample/SampleGroceryStore.java#L297)

However, I am able to get the source and sink connector working together, which should be the original use case behind this issue. The sink connector pushed the following message...

Thanks for your responses Ryan, especially over the weekend. I understand the scenario now and am able to properly reproduce it. I think it should definitely be possible to remove...

CSE Feedback filed: https://csefy19.visualstudio.com/CSEng/_workitems/edit/414040/

Looking at how the other DB connectors have approached the source offset issue. Interestingly, most of them do not support multiple source tasks at all. MongoDB: https://jira.mongodb.org/browse/KAFKA-121 Debezium: https://github.com/debezium/debezium/blob/master/debezium-embedded/src/main/java/io/debezium/connector/simple/SimpleSourceConnector.java#L91 JDBC:...