Hi all,

I’d like to start the discussion for KAFKA-19759: Add built-in TTL 
(Time-to-Live) support for Kafka Streams State Stores.

JIRA: https://issues.apache.org/jira/browse/KAFKA-19759
KIP Wiki: (will be created shortly)

Streams users often need per-key TTL functionality (e.g., for cache-like state, 
per-key deduplication, or automatic cleanup).
Currently, this requires manual punctuators and tombstones.

This KIP proposes adding a built-in `withTtl(Duration ttl)` option to state 
stores,
which would handle key expiration and changelog consistency automatically.

Please see the JIRA for full details and general analysis.
Looking forward for a discussion and talk.

Best regards,
Ankur Sinha

Reply via email to