[KAFKA-8403] Make suppression results queriable

• Type: Improvement
• Status: In Progress
• Priority: Major
• Resolution: Unresolved
• Component/s: streams
• Labels: needs-kip
• Assignee: Dongjin Lee
• Reporter: John Roesler
• Created: 21/May/19 15:27
• Updated: 28/Dec/22 22:56

Description

WIP KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-508%3A+Make+Suppression+State+Queriable

The newly added KTable Suppress operator lacks a Materialized variant, which would be useful if you wanted to query the results of the suppression.

Suppression results will eventually match the upstream results, but the intermediate distinction may be meaningful for some applications. For example, you could want to query only the final results of a windowed aggregation.

 

Note: This is not the same as implementing on-disk suppression, which is capured here: https://issues.apache.org/jira/browse/KAFKA-7224

Issue Links

• links to: GitHub Pull Request #7184
• links to: GitHub Pull Request #8117
• mentioned in: Page Loading...