[DISCUSS] KIP-647: Add ability to handle late messages in streams-aggregation

2020-07-24 Thread Igor Piddubnyi
Hi everybody, I would like to start off the discussion for KIP-647: https://cwiki.apache.org/confluence/display/KAFKA/KIP-647%3A+Add+ability+to+handle+late+messages+in+streams-aggregation

[DISCUSS] KIP-647: Add ability to handle late messages in streams-aggregation

2020-07-27 Thread Igor Piddubnyi
Hi everybody, I would like to start off the discussion for KIP-647: https://cwiki.apache.org/confluence/display/KAFKA/KIP-647%3A+Add+ability+to+handle+late+messages+in+streams-aggregation

Re: [DISCUSS] KIP-647: Add ability to handle late messages in streams-aggregation

2020-08-25 Thread Igor Piddubnyi
preserved late records? -Matthias On 7/27/20 1:45 AM, Igor Piddubnyi wrote: Hi everybody, I would like to start off the discussion for KIP-647: https://cwiki.apache.org/confluence/display/KAFKA/KIP-647%3A+Add+ability+to+handle+late+messages+in+streams-aggregation <https://cwiki.apache.org/c