Mark Cho created KAFKA-7709: ------------------------------- Summary: ConcurrentModificationException occurs when iterating through multiple partitions in Sender.getExpiredInflightBatches Key: KAFKA-7709 URL: https://issues.apache.org/jira/browse/KAFKA-7709 Project: Kafka Issue Type: Bug Components: core Affects Versions: 2.1.0 Reporter: Mark Cho
In Sender.getExpiredInflightBatches method, delivery.timeout on multiple partitions causes ConcurrentModificationException due to the underlying Java collection being mutated while being iterated on. In Java HashMap, you cannot mutate the underlying map while iterating through it, as this will cause ConcurrentModificationException. -- This message was sent by Atlassian JIRA (v7.6.3#76005)