Skip to content

Commit c935970

Browse files
committed
KafkaRequestHandler make requestStats 'volatile'
1 parent 921942d commit c935970

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaCommandDecoder.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ public abstract class KafkaCommandDecoder extends ChannelInboundHandlerAdapter {
6262
private final LinkedBlockingQueue<ResponseAndRequest> requestQueue;
6363
@Getter
6464
@Setter
65-
protected RequestStats requestStats;
65+
protected volatile RequestStats requestStats;
6666
@Getter
6767
protected final KafkaServiceConfiguration kafkaConfig;
6868

0 commit comments

Comments
 (0)