Overview

Lenses K2K is an application that allows you to replicate Kafka topics from one Kafka cluster to another.

These docs are still under construction.

K2K is in alpha. We are iterating rapidly.

While in alpha, please:

• Do NOT deploy in Production.

• Newer versions may have breaking changes.

• We cannot guarantee the upgrade paths.

Feedback

Break it and give use feedback!

This is an alpha, an early release, and we expect rough edges. Please provide us with feedback so we can improve for the community.

You can provide feedback via:

Lenses Support Github Discussion

Community Slack Ask Marios Knowledge Base

What is K2K?

K2K is short for Kafka to Kafka.

It is a standalone application that allows you to replicate topic data from one Kafka cluster to another continuously.

Some of its characteristics:

• It comes as a Docker container.

• It's designed to run natively on Kubernetes and to scale easily.

• It's self-contained and does not depend on additional technologies, i.e. Kafka Connect.

• It is purposefully built from the ground up.

Current Features

• ✅ Exactly once message delivery.

• ✅ Schema replication between Schema Registries.

• ✅ Flexible topic routing.

Current Limitations

K2K is in active development, and this is the 1st alpha release.

• Supports only Schema Registries compatible with the Confluent Schema Registry API.

Roadmap

• Filtering, masking & obfuscation.

• Replicate consumer group offsets.

• Support for AWS Glue Schema Registries.

• Integration into Lenses for self-service deployment and observation.