conduktor.io ↗

KIP-851 — Add requireStable flag into ListConsumerGroupOffsetsOptions

Accepted Kafka 3.3 AdminTransactions

Adds a `requireStable` flag to `AdminClient.listConsumerGroupOffsets()` so callers can opt into seeing only stable (non-pending-transactional) committed offsets, consistent with the behavior available in `KafkaConsumer.committed()`. Previously the admin API always returned the latest committed offset regardless of in-flight transactions, making it impossible to observe only fully committed group state.

Protocol Impact

Fetch · OffsetFetch

Details

AuthorGuozhang Wang
StatusAccepted
Kafka Version3.3
WikiView on Apache Wiki
Created2022-07-01
Last Modified2022-07-07
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.