conduktor.io ↗

KIP-319 — Replace segments with segmentInterval in WindowBytesStoreSupplier

Accepted Kafka 2.1 Streams

Replaces the segments() method on WindowBytesStoreSupplier with a segmentInterval() method returning the duration of each segment in milliseconds rather than the segment count. The store cache uses segment interval (not count) to size itself correctly; returning segment count required callers to do the division themselves and made the interface semantically incorrect.

Details

AuthorJohn Roesler
StatusAccepted
Kafka Version2.1
JIRAKAFKA-7080
WikiView on Apache Wiki
Created2018-06-20
Last Modified2018-08-23
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.