Convert hashmap to concurrenthashmap in TransactionManagerUtils

pinterest · Oct 23, 2024 · 642adfd · 642adfd
1 parent 2295af3
commit 642adfd
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/psc/src/main/java/com/pinterest/psc/producer/transaction/TransactionManagerUtils.java b/psc/src/main/java/com/pinterest/psc/producer/transaction/TransactionManagerUtils.java
@@ -4,8 +4,8 @@
 import com.pinterest.psc.producer.transaction.kafka.KafkaTransactionManagerOperator;
 import org.apache.kafka.clients.producer.internals.TransactionManager;
 
-import java.util.HashMap;
 import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.Future;
 
 /**
@@ -21,7 +21,7 @@
  */
 public class TransactionManagerUtils {
 
-    private static final Map<String, TransactionManagerOperator> TXN_MANAGER_CLASSNAME_TO_OPERATOR = new HashMap<>();
+    private static final Map<String, TransactionManagerOperator> TXN_MANAGER_CLASSNAME_TO_OPERATOR = new ConcurrentHashMap<>();
 
     private static TransactionManagerOperator getOrCreateTransactionManagerOperator(Object transactionManager) {
         return TXN_MANAGER_CLASSNAME_TO_OPERATOR.computeIfAbsent(transactionManager.getClass().getName(), className -> {