Re: Problem with kafka-streams aggregate windowedBy

2018-10-30 Thread Pavel Koroliov
why+aren+t+offsets+being+committed+ > > and check if your offsets are really comitted > > Best regards > > Patrik > > > >> Am 29.10.2018 um 18:20 schrieb Pavel Koroliov : > >> > >> Hi > >> No, my application id doesn't change >

Re: Problem with kafka-streams aggregate windowedBy

2018-10-29 Thread Pavel Koroliov
Hi No, my application id doesn't change пн, 29 окт. 2018 г. в 19:11, Patrik Kleindl : > Hi > Does your applicationId change? > Best regards > Patrik > > > Am 29.10.2018 um 13:28 schrieb Pavel Koroliov : > > > > Hi everyone! I use kafka-streams, and i ha

Problem with kafka-streams aggregate windowedBy

2018-10-29 Thread Pavel Koroliov
Hi everyone! I use kafka-streams, and i have a problem when i use windowedBy. Everything works well until I restart the application. After restarting my aggregation starts from beginning. Code bellow: > > StreamsBuilder builder = new StreamsBuilder() > KStream stream = builder.stream(topic,