Debezium配置了ExtractNewRecordState转换,消息格式是扁平化的: - 元数据字段使用__前缀(__op, __table, __source_ts_ms, __deleted) - 业务数据字段直接在根级别 - 修改handleMessage方法正确解析扁平化格式 - 更新CDCEvent接口以匹配实际消息结构 Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> |
||
|---|---|---|
| .. | ||
| api | ||
| application | ||
| domain | ||
| infrastructure | ||
| shared | ||
| app.module.ts | ||
| main.ts | ||