Spark Couchbase連接器DCP

Question

我想知道基於DCP的流在Spark Couchbase官方連接器中是否穩定？這些文件指出，他們還沒有準備好在生產中使用。我們有沒有Java的例子？

另外，如果有人能在我試圖解決的使用情況，以及是否提供一些線索火花連接器是有道理的位置：

我們得到了有關從couchbase精簡版分貝一些徽章同步網關每日更新。現在，在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

由於該產品是GA，並且該功能未標記爲實驗，因此支持從Spark連接器進行DCP流式傳輸。如果功能不受支持，Couchbase會盡早引入功能並通過註釋將其標記爲實驗。這就是說，我知道在撰寫本文時，有一些已知的JVM核心DCP實現問題，預計在接下來的幾個星期（如果不是更早的話）將被修復。我所知道的一個肯定是在這裏跟蹤：https://issues.couchbase.com/browse/JVMCBC-312

已添加新的測試場景，並且Couchbase正在努力確保它在下一個版本之前的不同失敗/重新平衡模式下通過這些測試。