Run sharded cluster $ mongo --nodb new ShardingTest({ shards: 2, mongos: 1, rs: true }) In another session connect to mongos and run simple script for insert 10 records per second: $ mongo mongodb: //localhost:20009/foo MongoDB server version: 4.0.1 mongos> for (;;) {db.bar.insert({_id: ObjectId()}); sleep(100);} In third session connect to `mongos` and try to create change stream: $ mongo mongodb: //localhost:20009/foo MongoDB server version: 4.0.1 mongos> db.bar.count() 13116 mongos> db.bar.watch() mongos> On this step I expected see a change stream events, but watch() method wait one second and return empty result.