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

custom header with MongoDB Source Connector

    XMLWordPrintableJSON

Details

    • Icon: Question Question
    • Resolution: Gone away
    • Icon: Major - P3 Major - P3
    • None
    • None
    • None
    • None

    Description

      Hi Team,

      I am trying to add a custom header using following config but as mentioned that property not belong to managed connector.

      Please can you suggest how can we add a custom header.

       
      "transforms":"moveValueFieldsToHeader",
      "transforms.moveValueFieldsToHeader.type":"org.apache.kafka.connect.transforms.HeaderFrom$Value",
      "transforms.moveValueFieldsToHeader.fields":"correlationId",
      "transforms.moveValueFieldsToHeader.headers":"x-correlationId-id",
      "transforms.moveValueFieldsToHeader.operation":"move",

      Attachments

        Activity

          People

            robert.walters@mongodb.com Robert Walters
            waytohksharma@gmail.com Harish Sharma
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: