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)