WARN No topic set. Could not publish the message

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

Hi @BRIJ_MOHAN_GUPTA,

This is by design as Mongo Namespaces map to topics. Please see the source connector configuration properties. If you just want to publish the full document only - please use the publish.full.document.only=true configuration.

All the best,

Ross