Jason Gustafson created KAFKA-7831: -------------------------------------- Summary: Consumer SubscriptionState missing synchronization Key: KAFKA-7831 URL: https://issues.apache.org/jira/browse/KAFKA-7831 Project: Kafka Issue Type: Bug Reporter: Jason Gustafson Assignee: Jason Gustafson
ConsumerCoordinator installs a Metadata.Listener in order to update pattern subscriptions after metadata changes. The listener is invoked from NetworkClient.poll, which could happen in the heartbeat thread. Currently, however, there is no synchronization in SubscriptionState to make this safe. -- This message was sent by Atlassian JIRA (v7.6.3#76005)