使用 Java 中的 Azure Cosmos DB 进行发布/订阅的示例

问题描述

我需要一个带有 Azure Cosmos DB 的发布/订阅事件消息系统。我使用 Azure Cosmos DB Java SDK v4。

我尝试使用基于此示例 https://github.com/Azure-Samples/azure-cosmos-java-sql-api-samples/blob/main/src/main/java/com/azure/cosmos/examples/changefeed/SampleChangeFeedProcessor.java 的 ChangeFeedProcessor,但它没有按预期工作。

我的问题:

  • 饲料收集/容器继续增长。如何在所有活动节点都收到事件后删除事件?
  • 事件的延迟似乎相对较大。大约一分钟。
  • 只有一个节点接收事件。这对于负载平衡来说似乎很有趣,但这不是我的用例。

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)