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"]}
}
}
]