kafka-connect-transform-common

ExtractTopic

  CONNECTOR_TRANSFORMS: "extract-topic-name"
  CONNECTOR_TRANSFORMS_EXTRACT-TOPIC-NAME_TYPE: almeida.paulorocha.kafka.connect.transform.extracttopic.ExtractTopic
  CONNECTOR_TRANSFORMS_EXTRACT-TOPIC-NAME_VALUE: "header.topic"
  CONNECTOR_TRANSFORMS_EXTRACT-TOPIC-NAME_DELIMITER: \\.

Sample payload

{
    "header": {
        "topic": "target-topic-name"
    },
    "body": {
        "name": "Paulo",
        "surname": "Almeida",
        "dateOfBirth": "24-10-1990"
    }
}

Router

  CONNECTOR_TRANSFORMS: "router"
  CONNECTOR_TRANSFORMS_ROUTER_TYPE: almeida.paulorocha.kafka.connect.transform.router.Router
  CONNECTOR_TRANSFORMS_ROUTER_MAPPINGS_FILE_PATH: "<path-to-mappings-json>"

Mappings File:

[
  {
    "from": "in-1",
    "to": "out-1"
  },
  {
    "from": "in-2",
    "to": "out-2"
  }
]