KIP-734 — Improve AdminClient.listOffsets to return timestamp and offset for the record with the largest timestamp

Accepted Kafka 3.0 Admin

Adds OffsetSpec.MaxTimestampSpec to AdminClient.listOffsets(), returning the offset and timestamp of the record carrying the highest message timestamp in a partition. Provides a lightweight liveness indicator for partitions without requiring a consumer or metric scrape, noting that MM2 timestamp preservation means this may not equal the latest append time.

Protocol Impact

ListOffsets v7

Details