conduktor.io ↗

KIP-122 — Add Reset Consumer Group Offsets tooling

Accepted Kafka 1.0 ConsumerAdmin

Adds a `kafka-consumer-groups.sh --reset-offsets` subcommand that can reset consumer group offsets to earliest, latest, a specific offset, a specific datetime, or a relative shift, with `--dry-run` and `--execute` modes. Previously, offset resets required writing custom consumer code that called `KafkaConsumer#seek()`, redeploy the app, then roll it back — a slow and error-prone process.

Details

AuthorJorge Esteban Quilcate Otoya
StatusAccepted
Kafka Version1.0
JIRAKAFKA-4743
WikiView on Apache Wiki
Created2017-02-08
Last Modified2018-11-08
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.