Flink CDC 里使用flink1.16.2报错怎么办？

Flink CDC 里使用flink1.16.2用flink-sql-connector-mongodb-cdc-2.3.0.jar，使用sql-client时，查询报错，什么原因。 报错：com.mongodb.MongoCommandException: Command failed with error 40573 (Location40573): 'The $changeStream stage is only supported on replica sets' on server 172.18.0.121:27017. The full response is {"ok": 0.0, "errmsg": "The $changeStream stage is only supported on replica sets", "code": 40573, "codeName": "Location40573"} 之前还报这个错：Exception authenticating MongoCredential{mechanism=SCRAM-SHA-1, userName='getdata', source='admin', 我的数据库是test 但source却是admin，什么原因。这是sql-client配置：) WITH (
'connector' = 'mongodb-cdc',
'hosts' = '172.18.0.121:27017',
'username' = 'flinkuser',
'password' = 'flinkpw',
'database' = 'test',
'collection' = 'YfyOriginalAuth'
);之前还报这个错：Exception authenticating MongoCredential{mechanism=SCRAM-SHA-1, userName='getdata', source='admin', 我的数据库是test 但source却是admin，什么原因？