Uploaded image for project: 'Kafka Connector'
  1. Kafka Connector
  2. KAFKA-248

WARN No topic set. Could not publish the message

    XMLWordPrintableJSON

Details

    • Icon: Bug Bug
    • Resolution: Works as Designed
    • Icon: Unknown Unknown
    • None
    • None
    • None

    Description

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

       

      Attachments

        Activity

          People

            ross@mongodb.com Ross Lawley
            guptabrijmohan30@gmail.com BRIJ MOHAN GUPTA
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: