[KAFKA-7223] KIP-328: Add in-memory Suppression

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.1.0
• Component/s: streams
• Assignee: John Roesler
• Reporter: John Roesler
• Created: 31/Jul/18 18:00
• Updated: 24/Jan/19 13:47
• Resolved: 24/Jan/19 13:47

Description

As described in https://cwiki.apache.org/confluence/display/KAFKA/KIP-328%3A+Ability+to+suppress+updates+for+KTables.

 

This ticket is to implement Suppress, but only for in-memory buffers.

(depends on KAFKA-7222)

Issue Links

• depends upon: KAFKA-7222 KIP-328: Add Window Grace Period (and deprecate Window Retention)
• is depended upon by: KAFKA-7224 KIP-328: Add spill-to-disk for Suppression
• relates to: KAFKA-4587 Rethink Unification of Caching with Dedupping
• relates to: KAFKA-6556 allow to attach callbacks in kafka streams, to be triggered when a window is expired
• links to: GitHub Pull Request #5567
• links to: GitHub Pull Request #5687
• links to: GitHub Pull Request #5688
• links to: GitHub Pull Request #5693
• links to: GitHub Pull Request #5710
• links to: GitHub Pull Request #5724
• links to: GitHub Pull Request #5731
• links to: GitHub Pull Request #5742
• links to: GitHub Pull Request #5787
• links to: GitHub Pull Request #5795
• links to: GitHub Pull Request #6024
• mentioned in: Page Loading...