Dynamic window size for aggregations

Hi all, We have a requirement to implement aggregations with TimedWindows which may have varying window sizes. For example, I may want a tumbling window that tumbles on 31st of Jan and 28th of Feb, 31st of March and so on. We did initial analysis of TimedWindows. Found that the windoSize is being

Re: Dynamic window size for aggregations

to create a feature request JIRA. For now, you could use a custom processor (via `.transform()`) that uses an attached window store to implement the logic you need. -Matthias On 4/9/19 4:09 AM, Rajesh Kalyanasundaram wrote: > Hi all, > We have a requirement to im

Minimum replication for Exactly Once semantics

Hi all, Kafka Streams application with Exactly once processing semantics, the default replication factor of broker is 3 i.e transaction.state.log.replication.factor In doc its mentioned that atleast 3 brokers are required for exactly once. What is the minimum replication factor required for exac