The passthrough change stream source workload should add data to the mongod collection with majority WC (ensure document is durably persisted for change stream to read, rather than in-memory), and then start the stream processor to consume from it rather than trying to insert messages into mongod collection while the stream processor is consuming from it