kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Pierre Coquentin <pierre.coquen...@gmail.com>
Subject Re: Synchronized block in StreamTask
Date Thu, 28 Jul 2016 07:32:33 GMT
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 <manikumar.reddy@gmail.com>
wrote:

> You already got reply from Guozhang on dev mailing list.
>
> On Thu, Jul 28, 2016 at 7:09 AM, Pierre Coquentin <
> pierre.coquentin@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" 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 by a specific thread
> > org.apache.kafka.streams.processor.internals.StreamThread.
> > Am I missing something ? Or, as the API is unstable, this class is meant
> in
> > the future to be shared between several threads ?
> >
> > Regards,
> >
> > Pierre
> >
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message