Change data capture | Debezium | MongoDB

Working with Data Connectors & Integrations
,
1

Hello Everyone, I am trying to enable change data capture for MongoDB using debezium connector but after creating the topic I am getting below exception and connector is going to failed state.

Can anyone advise what would be causing it? I am quite new to this please pardon me if I am asking silly question.

Thanks in advance for you help.

Exception below

Caused by: org.apache.kafka.connect.errors.ConnectException: Error while attempting to read from oplog on 'rs0-receipts/MONGO_HOST_IP:27017'
        at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.lambda$establishConnectionToPrimary$3(MongoDbStreamingChangeEventSource.java:182)
        at io.debezium.connector.mongodb.ConnectionContext$MongoPrimary.execute(ConnectionContext.java:292)
        at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.streamChangesForReplicaSet(MongoDbStreamingChangeEventSource.java:122)
        ... 10 more
Caused by: com.mongodb.MongoCommandException: Command failed with error 40415 (Location40415): 'BSON field '$changeStream.allChangesForCluster' is an unknown field.' on MONGO_HOST_IP:27017. The full response is {"operationTime": {"$timestamp": {"t": 1656174301, "i": 1503}}, "ok": 0.0, "errmsg": "BSON field '$changeStream.allChangesForCluster' is an unknown field.", "code": 40415, "codeName": "Location40415", "$clusterTime": {"clusterTime": {"$timestamp": {"t": 1656174301, "i": 1503}}, "signature": {"hash": {"$binary": {"base64": "H6N5rbGk/CNH8SyApfZrfUEoSig=", "subType": "00"}}, "keyId": 7081344251451146637}}}