MongoDB工具 >MongoDB Kafka连接器 >水槽连接器指南 > 接收器更改数据捕获
您可以使用Debezium随附的处理程序之一或扩展抽象类CdcHandler的自定义处理程序,将接收器连接器配置为处理CDC流中的数据。
要创建CDC处理程序,请指定以下配置信息:
change.data.capture.handler
属性中CDC处理程序的完整类名
。指定此配置设置后,连接器将在CDC操作模式下运行。topics
属性中的数据的主题。collection
属性。[key|value].converter
。JSON + Schema和AVRO格式均受支持。以下示例JSON有效负载在发布到Kafka Connect REST端点时,将使用指定的CDC配置实例化一个新的连接器: