Re: Reprocessing messsages in kafka streams vs Transformer init

2022-10-08 Thread xardaso
all dirty > writes from the state store during failure recovery. > > I hope this helps! > > Thanks, > John > > On Fri, Oct 7, 2022, at 15:57, xardaso wrote: > > > Hi Everyone, > > > > I have a question related to messages auto reprocessing in k

Reprocessing messsages in kafka streams vs Transformer init

2022-10-07 Thread xardaso
Hi Everyone, I have a question related to messages auto reprocessing in kafka streams and Transformer/Processor init()/close() methods. Is possible that in some scenarios (failures, rebalance etc.) a message is processed twice by Transformer.transform() without calling Transformer.init() betwe