apache-kafka - CDC（更改数据捕获）与 Couchbase

我需要从数据流中捕获更改。下面给出的是我的解决方案。

数据流入 Kafka -> Consumer 获取数据并将数据插入/更新（修剪后的数据）到 DynamoDB（我们已经配置了 DynamoDB 流）。每次插入/更新后，都会使用更改的数据生成一个流，然后由 Lambda 解释和处理。

现在我的问题是，如果必须用 Couchbase 替换 DynamoDB，Couchbase 会提供开箱即用的 CDC 吗？我对 Couchbase 非常陌生，我尝试搜索 CDC 功能，但没有直接文档。

任何指针都会非常有帮助！谢谢！

标签： apache-kafkaamazon-dynamodbcouchbaseamazon-dynamodb-streamschange-data-capture

Couchbase 有一个官方支持的 Kafka 连接器（此处的文档）。

我不熟悉“CDC”这个术语，但是这个 Couchbase Kafka 连接器可以充当接收器和源。它本身并不是“开箱即用”，它是一个单独的连接器。