Change Streams 支持实时数据变更推送，适合事件驱动架构。

核心概念

• 基于 oplog，需复制集或分片集群。
• 支持插入、更新、删除等事件类型。
• 可与消息队列集成。

实战步骤

• 使用 watch() API 监听集合或数据库级别变更。
• 处理恢复简历点 (resumeToken)。
• 构建去重与重试机制。

进阶建议

• 结合 Kafka Connector 同步到下游系统。
• 在微服务之间传播领域事件。
• 监控 Change Stream 延迟与错误。