Kafka Sink Connector

Overview

The Kafka Sink Connector is part of the Kafka Synchronisation Connectors project and can be used to load data from Kafka topics to topics on another Kafka Cluster.

Features

  • Load data from local Kafka topics to topics on a remote Kafka cluster

  • Copies the full record, including Kafka Headers

  • Mark copied headers with prefix

  • Add new static headers to records

  • Add original position of record as header for tracing

  • Supports multiple strategies for determining remote topic name

License

Kafka Synchronisation Connectors is licensed under the Apache License, Version 2.0.

Source code

The source code for the connector can be found on Axual Public repository