[
https://issues.apache.org/jira/browse/KAFKA-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nil Madhab reassigned KAFKA-18785:
----------------------------------
Assignee: Nil Madhab
> Add emitStrategy for co-grouped windowed aggrgation
> ---------------------------------------------------
>
> Key: KAFKA-18785
> URL: https://issues.apache.org/jira/browse/KAFKA-18785
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Affects Versions: 3.3.0
> Reporter: Matthias J. Sax
> Assignee: Nil Madhab
> Priority: Major
> Labels: need-kip
>
> We added the new `emitStrategy()` feature for windowed-aggregations via
> KIP-825
> [https://cwiki.apache.org/confluence/display/KAFKA/KIP-825%3A+introduce+a+new+API+to+control+when+aggregated+results+are+produced]
>
> However, we only added it for single KStream aggregations, but missed to also
> add it for co-grouped-windowed aggregations.
> If, we should add `emitStrategy()` to `TimeWindowedCogroupedKStream` and `
> SessionWindowedCogroupedKStream`
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
