From 7da1973f52e1c9b6b38bb0573183806adfbc5b42 Mon Sep 17 00:00:00 2001 From: Massimiliano Mirelli Date: Tue, 7 Mar 2023 14:10:44 +0200 Subject: [PATCH] Make ThreadLocal instance final --- .../nosqlbench/adapter/kafka/ops/OpTimeTrackKafkaProducer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/ops/OpTimeTrackKafkaProducer.java b/adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/ops/OpTimeTrackKafkaProducer.java index c5e032427..c1bd8165f 100644 --- a/adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/ops/OpTimeTrackKafkaProducer.java +++ b/adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/ops/OpTimeTrackKafkaProducer.java @@ -50,7 +50,7 @@ public class OpTimeTrackKafkaProducer extends OpTimeTrackKafkaClient { private final boolean asyncMsgAck; private final boolean transactEnabledConfig; private final int txnBatchNum; - private ThreadLocal> MessageSequenceNumberSendingHandlersThreadLocal = + private final ThreadLocal> MessageSequenceNumberSendingHandlersThreadLocal = ThreadLocal.withInitial(HashMap::new); private final boolean seqTracking; private final Set errSimuTypeSet;