Как установить Observables для прослушивания разных событий из ведра? Таким образом, всякий раз, когда новый документ, добавленный в ведро или существующий обновленный документ, я могу прочитать их и нажать на пункт назначения.Couchbase: Получение недавно добавленных или недавно обновленных документов из ведра
Примечание: просто начните с couchbase.
В настоящее время SDK не предлагает API для прослушивания изменений в базе данных. Это то, что может быть построено как фасад поверх DCP, протокол для репликации перекрестного центра обработки данных, на более поздний момент времени
Чтобы добавить больше к тому, что сказал Саймон, вы можете написать свой собственный DCP разъем. DCP предоставляет поток изменений, которые вы ищете, но у вас должен быть разъем, который будет поглощать этот поток. Если это то, что вам может понадобиться, я бы посмотрел на код для существующих коннекторов, например Kafka connector, и посмотрел, можете ли вы использовать их для создания своих собственных.
Как сказал Кирк, вы можете определенно использовать DCP для этого, пока вы в порядке с записью его на Java, потому что это единственный SDK, который в настоящее время имеет (экспериментальную) поддержку для потоковой передачи документов.
Как это происходит, Дэвид Майер написал шаг за шагом учебник о том, как реализовать уведомления слушателя изменений для Couchbase: http://nosqlgeek.blogspot.co.il/2015/05/dcp-magic.html
Вы ищете, когда какой-либо документ обновляется или конкретный один обновляется? – Kirk
Любой документ обновляется. –