conduktor.io ↗

KIP-1239 — Batch offset translation in RemoteClusterUtils

Accepted Kafka 4.3 MirrorMakerConsumer

Adds a batch overload to RemoteClusterUtils.translateOffsets() that accepts multiple consumer groups and translates their offsets in a single pass over the MirrorCheckpointConnector checkpoints topic. The existing single-group method fully scans the checkpoints topic per call, making mass offset translation during disaster recovery or manual failover prohibitively slow for environments with many consumer groups.

Details

AuthorMickael Maison
StatusAccepted
Kafka Version4.3
JIRAKAFKA-20229
WikiView on Apache Wiki
Created2025-11-17
Last Modified2026-02-26
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.