带有Couchbase的CDC（更改的数据捕获）

Question

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

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

现在我的问题是，如果必须用Couchbase替换DynamoDB，Couchbase是否可以提供现成的CDC？我对Couchbase相当陌生，我尝试搜索CDC功能，但没有直接的文档。

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

Answer 1

Couchbase具有官方支持的Kafka连接器（documentation here）。

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