Azure / azure-cosmosdb-java

Java Async SDK for SQL API of Azure Cosmos DB
MIT License
54 stars 61 forks source link

ChangeFeed processor library #86

Closed chetanmeh closed 5 years ago

chetanmeh commented 5 years ago

For some of the usecases we plan to make use of CosmosDB change feed support. Per the docs there are few option including using a change feed processor library or using low level change feed api.

For java I see there is a java library which is using sync documentdb java sdk. azure-cmosmosdb-java also provides a low level api to access change feed.

Would like to know which approach to take. Would the existing library using sync sdk is the way to go or there is any library implemented using the async sdk. Or if there are examples which use the async sdk

moderakh commented 5 years ago

@chetanmeh async java sdk already has support for low level change feed api. https://docs.microsoft.com/en-us/java/api/com.microsoft.azure.cosmosdb.rx.asyncdocumentclient.querydocumentchangefeed?view=azure-java-stable#com_microsoft_azure_cosmosdb_rx_AsyncDocumentClient_queryDocumentChangeFeed_String_ChangeFeedOptions_

We are building change feed processor support for the async sdk. For the long run async SDK is the way to go however if you want to do POC you can try the existing changefeed processor lib.

chetanmeh commented 5 years ago

We are building change feed processor support for the async sdk.

Thats promising.

if you want to do POC you can try the existing changefeed processor lib

Implemented one and it works fine. Change feed support is pretty useful and we plan to have few services making use of this feature. So looking forward for async sdk based library implementation to be published.

chetanmeh commented 5 years ago

@christopheranderson Any updates on async sdk based implementation for changefeed processor?

dzmitryverkhovin commented 5 years ago

@christopheranderson any ETA on changefeed processor library based on async sdk?

christopheranderson commented 5 years ago

This is available in V3 SDK now