用途:当数据库变更需要经 Debezium 与 Kafka Connect 捕获并投递时使用该技能,帮助智能体定义 connector 安全性、快照行为、schema 处理与下游 CDC 契约。适用于为 PostgreSQL、MySQL、MongoDB、SQL Server 或 Oracle 搭建 Debezium connector,设计基于 Kafka 的 CDC,处理初始快照、增量流与 connector 恢复,向流处理、lakehouse 落地或搜索索引供数,以及源表变更时的 schema 演进。若应用层事件或批量抽取已满足时效要求,则不应使用。
主要能力与流程:定义源表、键与变更事件语义,明确捕获与排除的表、主键唯一键策略、预期操作(插入、更新、删除、truncate)、是否为压缩主题生成 tombstone、变更量与峰值吞吐。显式规划快照:首次启动全表扫描,选择 initial、schema_only、never 或 when_needed 模式,理解 PostgreSQL 与 MySQL 快照锁行为,评估大表耗时并记录中断后果。配置运维韧性:max.batch.size、poll.interval.ms、心跳间隔以防 WAL/binlog 积压,定义源端 slot 或 binlog 保留策略,规划任务失败与自动重启,监控 lag 与 offset。定义主题契约:命名 {prefix}.{schema}.{table}、事件信封含 before/after、操作类型与源元数据、schema registry 集成、保留与压缩策略及消费者清单。安全处理演进:DDL 变化传播,在 registry 定义兼容策略,测试下游消费。规划恢复:slot 溢出或 binlog 过期处理、重新快照、数据库故障转移与告警。
限制:资料未提供具体安装命令、价格或平台信息;需注意 Debezium 为至少一次投递,下游须去重或幂等,且 connector 需持续监控。