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)
