Guozhang Wang created KAFKA-3855:
------------------------------------
Summary: 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
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)