CD C (измененный ввод данных) с Couchbase

Question

У меня есть требование фиксировать изменения из потока данных. Ниже дано мое решение.

Потоки данных в Kafka -> Потребитель Собирает данные и вставляет / обновляет (урезанные данные) в DynamoDB (мы настроили потоки DynamoDB). После каждой вставки / обновления создается поток с измененными данными, который затем интерпретируется и обрабатывается лямбда-выражением.

Теперь у меня вопрос: придется ли заменять DynamoDB на Couchbase, предоставит ли Couchbase CD C из коробки? Я довольно новичок в Couchbase, и я попытался найти функцию CD C, но не нашел прямой документации.

Любые указатели были бы очень полезны! Спасибо!

Answer 1

Couchbase имеет официально поддерживаемый разъем Kafka (документация здесь ).

Я не знаком с термином "CD C", но этот разъем Couchbase Kafka может действовать как и приемник, и источник. Это не "из коробки" как таковое, это отдельный разъем.