Kafka Source Connector

Overview

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

Features

  • Load data to local Kafka topics from 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 local 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