用途：该技能为 ClickHouse + Kafka 数据管道提供生产可用的纵深防御（defense-in-depth）校验模式，在生产者与消费者两端保障数据完整性，并在不阻塞消费的前提下处理错误、自动去重并提供监控观测。适用于新建 Kafka+ClickHouse 管道、ClickHouse 出现重复记录、畸形消息阻塞消费、需要数据完整性的事件驱动架构，以及排查消息丢失、类型校验失败、Schema 演进破坏管道等场景。
主要能力：
- ClickHouse 错误流：通过 kafka_handle_error_mode = 'stream' 将畸形消息写入独立错误表，而非阻塞消费；用物化视图捕获 _error 非空的记录，并保留 topic、partition、offset 等元数据。
- 幂等与去重：使用 ReplacingMergeTree 应对至少一次投递语义，实现自动去重。
- 生产者校验：用 msgspec 冻结（frozen）结构定义类型安全 Schema，校验失败转换为领域异常并记录日志。
- 消费者校验：通过防腐层（anti-corruption layer）在消费端再次校验时间戳、业务规则与行项目约束，并转换为领域实体。
- 监控与测试：提供错误率查询、告警阈值（如 >20 errors/sec）、仪表盘与运行手册建议，以及单元/集成/去重/Schema 演进测试模式。
必要用法（资料内命令保持原样）： ALTER TABLE kafka_orders MODIFY SETTING kafka_handle_error_mode = 'stream'; 依赖：msgspec>=0.18.0、clickhouse-driver>=0.2.6、confluent-kafka>=2.3.0、pydantic>=2.5.0（可选）；ClickHouse 21.6+ 才支持该错误模式，更早版本需回退到 kafka_skip_broken_messages。
限制：需要理解 Clean Architecture 与有界上下文；具体部署、收费与平台支持情况资料未提供。