You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Mark Cho (JIRA)" <ji...@apache.org> on 2018/12/05 19:24:00 UTC

[jira] [Created] (KAFKA-7709) ConcurrentModificationException occurs when iterating through multiple partitions in Sender.getExpiredInflightBatches

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)