Description
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.
Attachments
Issue Links
- causes
-
KAFKA-9233 Kafka consumer throws undocumented IllegalStateException
- Resolved
- relates to
-
KAFKA-8623 KafkaProducer possible deadlock when sending to different topics
- Resolved
- links to