kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Manikumar Reddy <manikumar.re...@gmail.com>
Subject Re: Synchronized block in StreamTask
Date Thu, 28 Jul 2016 07:23:36 GMT
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