You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Justinwins (Jira)" <ji...@apache.org> on 2022/04/26 02:02:00 UTC
[jira] [Created] (KAFKA-13856) MirrorCheckpointTask meets ConcurrentModificationException
Justinwins created KAFKA-13856:
----------------------------------
Summary: MirrorCheckpointTask meets ConcurrentModificationException
Key: KAFKA-13856
URL: https://issues.apache.org/jira/browse/KAFKA-13856
Project: Kafka
Issue Type: Bug
Components: mirrormaker
Affects Versions: 3.0.1
Reporter: Justinwins
In MirrorCheckpointTask.java, the field
private Map<String, List<Checkpoint>> checkpointsPerConsumerGroup = new HashMap<>
may be modified ( used with put API) , and traversed by two different threads at the same time.
Clearly,this would incur ConcurrentModificationException.
This bug still exists in Trunk branch.
--
This message was sent by Atlassian Jira
(v8.20.7#820007)