conduktor.io ↗

Kafka ShareFetch Changelog — Protocol Version History

What is ShareFetch?

The main data path for share group consumers, fetching records and acknowledging previously fetched ones in a single round-trip (KIP-932). Records are locked on fetch with an acquisition timeout; if a consumer doesn't acknowledge within that window, the records become available for re-delivery.

VersionKafkaChanges
ShareFetchRequest
v14.1
+ MaxRecords int32
+ BatchSize int32
- PartitionMaxBytes int32
is the initial stable version (KIP-932).
v24.2
+ ShareAcquireMode int8
+ IsRenewAck bool
introduces ShareAcquireMode and Renew acknowledgements (KIP-1206 and KIP-1222).
ShareFetchResponse
v14.1
+ AcquisitionLockTimeoutMs int32
is the initial stable version (KIP-932).
v24.2
introduces ShareAcquireMode and Renew acknowledgements (KIP-1206 and KIP-1222).