Re: Out of order messages when kafka streams application catches up

2022-11-15 Thread Tomasz Gac
f you’re able to provide a repro, that would be awesome). > > > > Thanks, and sorry for the trouble. > > -John > > > > On Tue, Sep 27, 2022, at 03:15, Tomasz Gac wrote: > >> I upgraded to kafka streams 3.0.0 with positive task.max.idle.ms and > it d

Cannot send in state COMMITTING_TRANSACTION

2022-11-15 Thread Tomasz Gac
Hi group, We've encountered a problem during regular operation of the kafka-streams application. While processing a record we received the following error. There's very little documentation on this kind of problem but I've gathered that it's a synchronization issue between kafka consumer and produ

Re: Out of order messages when kafka streams application catches up

2022-09-27 Thread Tomasz Gac
gt; > On Mon, Sep 26, 2022, at 01:35, Tomasz Gac wrote: > > Hi group, > > > > I wrote a simple kafka streams application with topology such as below: > > > > builder.addStateStore( > >> Stores.keyValueStoreBuilder( > >&g

Out of order messages when kafka streams application catches up

2022-09-25 Thread Tomasz Gac
Hi group, I wrote a simple kafka streams application with topology such as below: builder.addStateStore( > Stores.keyValueStoreBuilder( > Stores.persistentKeyValueStore("STORE"), > Serdes.String(), Serdes.String()) > .withLoggingEnabled(storeConfig))| builder.stream("TOPIC_