Re: Synchronized block in StreamTask

2016-07-28 Thread Pierre Coquentin
Ok except that I messed up my subscription on dev and didn't receive anything, sorry, I will check in the archive to see the answer. Thanks, On Thu, Jul 28, 2016 at 9:23 AM, Manikumar Reddy wrote: > You already got reply from Guozhang on dev mailing list. > > On Thu, Jul 28, 2016 at 7:09 AM, Pi

Re: Synchronized block in StreamTask

2016-07-28 Thread Manikumar Reddy
You already got reply from Guozhang on dev mailing list. On Thu, Jul 28, 2016 at 7:09 AM, Pierre Coquentin < pierre.coquen...@gmail.com> wrote: > Hi, > > I've a simple technical question about kafka streams. > In class org.apache.kafka.streams.processor.internals.StreamTask, the > method "process

Synchronized block in StreamTask

2016-07-28 Thread Pierre Coquentin
Hi, I've a simple technical question about kafka streams. In class org.apache.kafka.streams.processor.internals.StreamTask, the method "process" uses a synchronized block but I don't see why, the method doesn't seem to be called in a multi-threaded environnement as it's created and only accessed b