linkedin / linkedin/brooklin

kafka header not mirroring

Open
#665 0 comments 0 reactions 0 assignees View on GitHub
enhancement
Dominant language
Java
Stars
968
Forks
144
PR merge metrics
No merged PRs in 30d

Description

**Is your feature request related to a problem? Please describe.**
A clear and concise description of what the problem is.

I try to [Mirroring kafka clusters](https://github.com/linkedin/brooklin/wiki/Mirroring-Kafka-Clusters).
and I using same as tutorial.
but brooklin miss mirroring that kafka headers.

**Describe the solution you'd like**
A clear and concise description of what you want to happen.
kafka header also mirroring it.

**Describe alternatives you've considered**
A clear and concise description of any alternative solutions or features you've considered.

I checked "KafkaMirrorMakerConnectorTask.java".
I think add kafka header copy logic in `translate` method.

**Additional context**
Add any other context about the feature request here.

Contributor guide

Open the contributing guide

Research direction

Start with KafkaMirrorMakerConnectorTask.java and inspect the translate method, following the Mirroring Kafka Clusters tutorial linked in the issue. Trace how records are translated and determine where headers are currently omitted. Done means mirrored records retain their Kafka headers when using the documented mirroring setup.

Written by the indexing model from the issue text.

Assessment

Tech stack
java
Domain
distributed-systems, stream-processing
Issue type
Feature
Difficulty
3/5
Estimated time
1-2 days
Activity status
Stale
Clarity
Mostly clear
Newbie friendliness
35/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.