Azure-Samples / azure-cosmos-java-sql-api-samples

Sample code for Azure Cosmos DB Java SDK for SQL API
MIT License
38 stars 70 forks source link

ChangeFeedProcessorBuilder.handleAllVersionsAndDeletesChanges doesn't received any messages #56

Open survivant opened 1 year ago

survivant commented 1 year ago

I created a junit with the code from https://github.com/Azure-Samples/azure-cosmos-java-sql-api-samples/blob/fb3cee8e3d8faa69d97f6a61d4bf0633992426d0/src/main/java/com/azure/cosmos/examples/changefeed/SampleChangeFeedProcessorForAllVersionsAndDeletesMode.java

but when I run it with Cosmos DB emulator, I don't received messages with ChangeFeedProcessor and handleAllVersionsAndDeletesChanges.

I'm using the latest docker image version for the emulator : mcr.microsoft.com/cosmosdb/linux/azure-cosmos-emulator:latest

I created a project to reproduce the issue.

I have few tests

src/test/java/com/example/demoredis/CosmosDBTests.java (with .handleChanges and it works) src/test/java/com/example/demoredis/CosmosDBFeed3Tests.java : SampleChangeFeedProcessorForAllVersionsAndDeletesMode (doesn't work)

here the logs for CosmosDBFeed3Tests

[debug.log](https://github.com/Azure/azure-cosmos-db-emulator-docker/files/10297050/debug.log)

here my source code demo-cosmos-feed-update.zip