Guozhang Wang created KAFKA-1134: ------------------------------------ Summary: onControllerFailover function should be synchronized with other functions Key: KAFKA-1134 URL: https://issues.apache.org/jira/browse/KAFKA-1134 Project: Kafka Issue Type: Bug Reporter: Guozhang Wang
Otherwise race conditions could happen. For example, handleNewSession will close all sockets with brokers while the handleStateChange in onControllerFailover tries to send requests to them. -- This message was sent by Atlassian JIRA (v6.1#6144)