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
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
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
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_