conduktor.io ↗

KIP-330 — Add retentionPeriod in SessionBytesStoreSupplier

Accepted Kafka 2.1 Streams

KIP-330 adds a `retentionPeriod()` method to `SessionBytesStoreSupplier`, parallel to the existing method on `WindowBytesStoreSupplier`. Without it, the `StoreBuilder` wrapper cannot determine the appropriate changelog topic retention period for session stores, causing the changelog to use an incorrect or default retention that may not cover the full session window.

Details

AuthorGuozhang Wang
StatusAccepted
Kafka Version2.1
JIRAKAFKA-7101
WikiView on Apache Wiki
Created2018-06-27
Last Modified2018-07-02
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.