Charly Molter created KAFKA-6310: ------------------------------------ Summary: ConcurrentModificationException when reporting requests-in-flight in producer Key: KAFKA-6310 URL: https://issues.apache.org/jira/browse/KAFKA-6310 Project: Kafka Issue Type: Bug Components: metrics, network Affects Versions: 1.0.0 Reporter: Charly Molter
We are running in an issue really similar to KAFKA-4950. We have a producer running and a MetricsReporter with a background thread which publishes these metrics. The concurrent exception happens when calling `InFlightRequests.count()` in one thread when a connection or disconnection is happening. In this case one thread is iterating over the map while another is adding/removing from it thus causing the exception. We could potentially fix this with a volatile like in KAFKA-4950. -- This message was sent by Atlassian JIRA (v6.4.14#64029)