Re: Kafka Streams topology does not replay correctly

2018-01-18 Thread Dmitry Minkovsky
ansform before the settings-confirm > >>>>> transform before the settings-update transform? > >>>>> > >>>>> > >>>>> > >>>>> вт, 16 янв. 2018 г. в 21:39, Matthias J. Sax >: > >>>>>

Re: Kafka Streams topology does not replay correctly

2018-01-17 Thread Matthias J. Sax
t be able to buffer multiple records from the KTable and >>>>>> KStream input and also store the corresponding timestamps to perform >>> the >>>>>> join correctly. It's not trivial but also also not rocket-science. >>>>>> &g

Re: Kafka Streams topology does not replay correctly

2018-01-17 Thread Dmitry Minkovsky
so store the corresponding timestamps to perform >> the >> >>> join correctly. It's not trivial but also also not rocket-science. >> >>> >> >>> If we need stronger guarantees, it's the best way to follow though >> atm, >> >>&

Re: Kafka Streams topology does not replay correctly

2018-01-17 Thread Dmitry Minkovsky
> >>> > >>> -Matthias > >>> > >>> > >>> On 1/16/18 5:34 PM, Dmitry Minkovsky wrote: > >>>> Right now I am thinking of re-writing anything that has these > >>> problematic > >>>> KStream/KTab

Re: Kafka Streams topology does not replay correctly

2018-01-16 Thread Matthias J. Sax
> problematic >>>> KStream/KTable joins as KStream#transform() wherein the state store is >>>> manually used. Does that makes sense as an option for me? >>>> >>>> -Dmitry >>>> >>>> On Tue, Jan 16, 2018 at 6:08 PM, Dmitry Mi

Re: Kafka Streams topology does not replay correctly

2018-01-16 Thread Dmitry Minkovsky
inking of re-writing anything that has these >> problematic >> > KStream/KTable joins as KStream#transform() wherein the state store is >> > manually used. Does that makes sense as an option for me? >> > >> > -Dmitry >> > >> > On Tue, Ja

Re: Kafka Streams topology does not replay correctly

2018-01-16 Thread Dmitry Minkovsky
> > On Tue, Jan 16, 2018 at 6:08 PM, Dmitry Minkovsky > > wrote: > > > >> Earlier today I posted this question to SO > >> < > https://stackoverflow.com/questions/48287840/kafka-streams-topology-does-not-replay-correctly > > > >> : > >

Re: Kafka Streams topology does not replay correctly

2018-01-16 Thread Matthias J. Sax
Stream#transform() wherein the state store is > manually used. Does that makes sense as an option for me? > > -Dmitry > > On Tue, Jan 16, 2018 at 6:08 PM, Dmitry Minkovsky > wrote: > >> Earlier today I posted this question to SO >> <https://stackoverflow.co

Re: Kafka Streams topology does not replay correctly

2018-01-16 Thread Dmitry Minkovsky
ted this question to SO > <https://stackoverflow.com/questions/48287840/kafka-streams-topology-does-not-replay-correctly> > : > > > I have a topology that looks like this: > > KTable users = topology.table(USERS, > Consumed.with(byteStringSerde, userSerde), Materia

Kafka Streams topology does not replay correctly

2018-01-16 Thread Dmitry Minkovsky
Earlier today I posted this question to SO <https://stackoverflow.com/questions/48287840/kafka-streams-topology-does-not-replay-correctly> : > I have a topology that looks like this: KTable users = topology.table(USERS, Consumed.with(byteStringSerde, userSerde), Materialized