我想知道基于 DCP 的流在 Spark Couchbase 官方连接器中是否稳定?这些文件表明它们还没有准备好在生产中使用。我们有 Java 的例子吗?
另外,如果有人可以阐明我正在尝试解决的用例以及火花连接器在这里是否有意义:
我们每天都会从 couchbase lite db 到同步网关获取有关一些徽章的更新。现在,在 10 天的时间窗口内,如果有人获得 5 个或更多徽章,那么我们需要推送一个祝贺徽章。这需要每 10 天后进行一次。
因此,我计划使用 DCP,每天检查更改,运行作业,然后将其推送到同步网关。如果在 10 天的时间间隔内,获得了 5 个或更多徽章,那么我将其推送到同步网关..
这是解决这个问题的正确方法还是有更好的方法来做到这一点?
可以使用的另一件事是:
那么哪种方法会更好呢?