conduktor.io ↗

KIP-1021 — Allow to get last stable offset (LSO) in kafka-get-offsets.sh

Discussion AdminConsumer

Adds an --isolation flag to kafka-get-offsets.sh and extends OffsetSpec with an LSOSpec so that the last stable offset (LSO) can be fetched instead of the high watermark. Without this, the tool always uses IsolationLevel.READ_UNCOMMITTED, making it impossible to observe the true consumer-visible offset boundary for transactional topics.

Details

AuthorAhmed Sobeh
StatusDiscussion
JIRAKAFKA-16282
WikiView on Apache Wiki
Created2024-02-24
Last Modified2024-03-20
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.