I get this message when I launch the MongoDB source connector and perform an update on source DB:

“WARN No topic set. Could not publish the message (…)”

If I remove "ns" from the aggregation pipeline then it throws a warning message and does not insert the data into Topic. But if I add ns in the project operation then it is working fine. This may be the bug.

Current Pipeline:

[
{$match:
{"operationType": "insert"}
},
{$project:
{
"_id":1,

"identity_id": "$fullDocument.profile.userIdentityId",
"user_guid":"$fullDocument.userGuid",
"status": "$fullDocument.status",
"product_items": "$fullDocument.productItems",
"last_updated_on": {$subtract :["$$NOW","$fullDocument.lastUpdatedOn"]}
}
}
]