You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/07/18 16:55:20 UTC

[jira] [Assigned] (KAFKA-3855) Guard race conditions in TopologyBuilder

     [ https://issues.apache.org/jira/browse/KAFKA-3855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Damian Guy reassigned KAFKA-3855:
---------------------------------

    Assignee: Damian Guy

> Guard race conditions in TopologyBuilder
> ----------------------------------------
>
>                 Key: KAFKA-3855
>                 URL: https://issues.apache.org/jira/browse/KAFKA-3855
>             Project: Kafka
>          Issue Type: Bug
>          Components: streams
>            Reporter: Guozhang Wang
>            Assignee: Damian Guy
>              Labels: architecture
>
> The user specified {{TopologyBuilder}} is shared among all stream threads to build the processor topology instance, one for each thread. It public functions that can be accessed by the threads is not synchronized, and we need to double check if it could cause race conditions, and if yes guard against these concurrent access.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)