Spark Couchbase 连接器 DCP

Question

我想知道基于 DCP 的流在 Spark Couchbase 官方连接器中是否稳定？这些文件表明它们还没有准备好在生产中使用。我们有 Java 的例子吗？

另外，如果有人可以阐明我正在尝试解决的用例以及火花连接器在这里是否有意义：

我们每天都会从 couchbase lite db 到同步网关获取有关一些徽章的更新。现在，在 10 天的窗口中，如果有人获得 5 个或更多徽章，那么我们需要推送一个祝贺徽章。这需要每 10 天后进行一次。

所以，我的计划是使用 DCP，每天检查更改，运行作业，然后将其推送到同步网关。如果在 10 天的时间间隔内，获得了 5 个或更多徽章，那么我将其推送到同步网关..

这是解决此问题的正确方法还是有更好的方法？

还有一个可以使用的东西是：

http://developer.couchbase.com/documentation/mobile/1.2/develop/guides/sync-gateway/server-integration/changes-worker/index.html..

那么这里哪种方法更好？

Answer 1

支持来自 Spark 连接器的 DCP 流，因为该产品是 GA 并且该功能未标记为实验性。 Couchbase 确实会提前引入功能，如果该功能不受支持，则会通过注释将其标记为实验性。

也就是说，在撰写本文时，我知道 JVM Core DCP 实现存在一些已知问题，预计会在接下来的几周内得到解决，如果不是更早的话。我肯定知道的一个在这里被跟踪：https://issues.couchbase.com/browse/JVMCBC-312

已添加新的测试场景，Couchbase 正在努力确保它在下一个版本之前在不同的故障/重新平衡模式下通过这些测试。