[ 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)