change stream 仅支持副本集和分片集群，不支持主从架构，因其依赖oplog统一视图和选举机制；主从架构下会报commandnotsupportedonview或错误码40324。
Change Stream 为什么在主从架构里根本跑不起来
Change Stream 只支持副本集（Replica Set）和分片集群（Sharded Cluster），不支持纯主从（Master-Slave）部署。这是 MongoDB 官方硬性限制，不是配置问题，也不是权限或版本问题——主从架构压根没有 oplog 的统一视图和选举机制，changeStream 驱动一连接就报 CommandNotSupportedOnView 或直接抛 FailedToParse: change stream is not supported on this topology。
常见错误现象：
- 应用日志里反复出现
TopologyDescription{type=Unknown}或No primary available - 调用
collection.watch()后立刻抛出MongoCommandException，错误码为40324（UnsupportedOplogOperation） - 即使连上了主节点，驱动内部仍拒绝初始化 change stream，因为拓扑检测失败
怎么确认自己是不是真在副本集模式下
别信配置文件名或启动参数里写了 --replSet 就算数。必须进 mongo shell 连任意节点执行：rs.status()，看返回里有没有 members 数组、myState 是否为 1（主）或 2（从），且 ok: 1。
容易踩的坑：
- 本地测试时用
mongod --port 27017 --dbpath /data/db单节点启动，没执行rs.initiate()—— 这只是单机，不是副本集 - 副本集初始化后没等
rs.status().members[0].stateStr === "PRIMARY"就急着开 watch，此时主节点尚未完成选举，watch()会因找不到可用 primary 而超时 - 连接字符串写成
mongodb://localhost:27017/mydb（单节点地址），而不是mongodb://node1:27017,node2:27017,node3:27017/mydb?replicaSet=myrs
watch() 调用前必须检查的三件事
就算拓扑对了，collection.watch() 也可能静默失败或漏事件。关键不在代码写法，而在服务端状态：
- 目标集合必须有开启的
changeStreamPreAndPostImages（MongoDB 6.0+）：执行db.runCommand({collMod: "mycol", changeStreamPreAndPostImages: {enabled: true}})，否则fullDocumentBeforeChange拿不到旧值 - 用户权限必须包含
changeStream动作：角色至少含clusterMonitor或自定义角色中显式声明"actions": ["changeStream"] - oplog 大小要够撑住你设置的
startAfter或resumeAfter：如果 resume token 对应的 oplog 条目已被轮转掉，会直接报CursorNotFound，不是重试能解决的
监听时最容易被忽略的兼容性细节
Change Stream 不是“开箱即用”的实时管道，它的行为高度依赖 MongoDB 版本和驱动版本匹配：
- MongoDB 4.0+ 才支持 collection-level watch；4.2+ 支持 pipeline 过滤；5.0+ 支持
showExpandedEvents；6.0+ 强制要求 pre/post image 显式开启 - Node.js 驱动必须 ≥ 3.6.0（对应 MongoDB 4.2），但如果你用的是 4.4+ server，建议驱动升到 4.13+，否则
resumeAfter在网络抖动后可能跳过变更 - Java 驱动里
ChangeStreamIterable默认不自动重连，需手动设.maxAwaitTime(30, TimeUnit.SECONDS)并捕获MongoInterruptedException做恢复逻辑
真正麻烦的从来不是语法怎么写，而是你改完配置、重启 mongod、再跑一遍 watch，结果发现 oplog 窗口太小、权限没刷、驱动版本锁在旧包里——这些点串起来，才构成一个能长期稳定工作的 change stream。
