[ https://issues.apache.org/jira/browse/KAFKA-7709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Guozhang Wang resolved KAFKA-7709. ---------------------------------- Resolution: Fixed Fix Version/s: 2.1.1 2.2.0 Thanks [~markcho] for your contribution! > 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 > Priority: Major > Fix For: 2.2.0, 2.1.1 > > > 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)