Connecteur Spark Couchbase DCP

Question

Je voulais savoir si le streaming basé sur DCP est stable dans Spark Couchbase Official Connector? Les documents indiquent qu'ils ne sont pas encore prêts à être utilisés en production. Avons-nous des exemples pour Java?

De plus, si quelqu'un pouvait faire la lumière sur le cas d'utilisation que je suis en train de résoudre et si un connecteur d'allumage est logique ici:

Nous recevons des mises à jour quotidiennes sur des badges à partir d'un db lite Couchbase à la passerelle synchroniser . Maintenant, sur une fenêtre de 10 jours, si quelqu'un gagne 5 badges ou plus, alors nous devons pousser un badge de félicitations. Cela doit être fait tous les 10 jours. Donc, ce que je prévoyais était que, en utilisant le DCP, je vérifie les changements sur une base quotidienne, exécute un travail et ensuite le pousser pour synchroniser la passerelle. Si dans l'intervalle de 10 jours, 5 badges ou plus ont été gagnés, alors je le pousse à la passerelle de synchronisation.

Est-ce la bonne façon de faire cela ou y at-il de meilleures façons de le faire?

Une chose qui pourrait être utilisé est:

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

Alors quelle approche serait mieux d'ici?

Answer 1

La diffusion en continu DCP à partir de Spark Connector est prise en charge car ce produit est GA et cette fonctionnalité n'est pas marquée expérimentale. Couchbase introduit les fonctionnalités de manière anticipée et les marque expérimentalement par des annotations si la fonctionnalité n'est pas prise en charge. Cela dit, je sais qu'il y a des problèmes connus avec l'implémentation JVM Core DCP au moment de la rédaction de ce document, qui devraient être corrigés dans les deux semaines à venir, sinon plus tôt. Celui que je connais est bien sûr suivi ici: https://issues.couchbase.com/browse/JVMCBC-312

De nouveaux scénarios de test ont été ajoutés et Couchbase travaille pour s'assurer qu'il passe ces tests lors de différents modes de défaillance/rééquilibrage avant la prochaine version.