Hi All,
I have a requirement to project only few fields from the mongo collection document using pipeline project statement we are not able to achieve it. The pipeline is working when i omit the specific fields using the pipeline as mentioned in the documentation (https://www.mongodb.com/docs/kafka-connector/v1.10/source-connector/usage-examples/custom-pipeline/#std-label-source-usage-example-custom-pipeline) but our requirement to accept only specfic fields (ex: pipeline=[{“$match”: { “$and”: [{“operationType”: “insert”}, { “fullDocument.eventId”: 321 }] } }, {“$project”: { “fullDocument._id”: 1, “fullDocument.eventId”: 1} } ])when applied the project the connector unable to listen to the change events.