You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by Igor Piddubnyi <ig...@gmail.com> on 2020/07/24 10:30:53 UTC

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

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/confluence/display/KAFKA/KIP-594%3A+Expose+output+topic+names+from+TopologyTestDriver>

This KIP proposes a minor adjustment in the kafka-streams aggregation-api, adding a processing for late messages.
[WIP] PR here: https://github.com/apache/kafka/pull/9017

Please check.
Regards, Igor.