Kafka Stream - How to calculate and send a Diff message in an aggregation method

Hello, I'm using KafkaStream for some months and I don't succeed to implement this use case : I need to compare two objects : a new one and the old one. At the end, I need to send a message with the diff between the 2 objets. My first implementation was to use an aggregate and to return the diff

Re: Kafka Stream - How to calculate and send a Diff message in an aggregation method

alues that compare the diff over both -- > ie, it's a two step approach instead of a single aggregation. > > About the Producer solution. This is indeed not recommended. For the > exception itself, it's a know bug and a fix was proposed via KIP-91. > > > -Matthias > > O

Re: Kafka Stream - How to calculate and send a Diff message in an aggregation method

tml > > > -Matthias > > On 12/23/17 1:28 AM, Cedric BERTRAND wrote: > > Thanks for your answer. > > > > The aggregation followed with a mapvalue was my first implementation but > I > > loose some message in the mapvalue step. > > > > Whe

Kafka Stream - Building KTable in Kafka 1.0.0

Hello, In the new api 1.0.0 for building KTable, it is written that No internal changelod topic is created. public KTable table(java.lang.String topic) Create a KTable