This is an automated email from the ASF dual-hosted git repository.
lianetm pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new cad46800c35 MINOR: Fix thread safety issue in CoordinatorTimerImpl by
using ConcurrentHashMap (#21376)
cad46800c35 is described below
commit cad46800c3580f669f3076e19e4a1a8bf47ac351
Author: Lan Ding <[email protected]>
AuthorDate: Fri Jan 30 22:52:11 2026 +0800
MINOR: Fix thread safety issue in CoordinatorTimerImpl by using
ConcurrentHashMap (#21376)
Fix thread safety issue in `CoordinatorTimerImpl` by using
`ConcurrentHashMap`.
Reviewers: Ken Huang <[email protected]>, Sean Quah
<[email protected]>, Lianet Magrans
<[email protected]>
---
.../apache/kafka/coordinator/common/runtime/CoordinatorTimerImpl.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorTimerImpl.java
b/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorTimerImpl.java
index b99e396da77..a3cdeacf6ad 100644
---
a/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorTimerImpl.java
+++
b/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorTimerImpl.java
@@ -24,9 +24,9 @@ import org.apache.kafka.server.util.timer.TimerTask;
import org.slf4j.Logger;
-import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.TimeUnit;
@@ -42,7 +42,7 @@ public class CoordinatorTimerImpl<U> implements
CoordinatorTimer<U> {
private final Logger log;
private final Timer timer;
private final CoordinatorShardScheduler<U> scheduler;
- private final Map<String, TimerTask> tasks = new HashMap<>();
+ private final Map<String, TimerTask> tasks = new ConcurrentHashMap<>();
public CoordinatorTimerImpl(
LogContext logContext,
