chia7712 commented on a change in pull request #8978:
URL: https://github.com/apache/kafka/pull/8978#discussion_r449728663
##########
File path: clients/src/test/java/org/apache/kafka/test/MockDeserializer.java
##########
@@ -26,17 +26,16 @@
public class MockDeserializer implements ClusterResourceListener,
Deserializer<byte[]> {
public static AtomicInteger initCount = new AtomicInteger(0);
- public static AtomicInteger closeCount = new AtomicInteger(0);
public static AtomicReference<ClusterResource> clusterMeta = new
AtomicReference<>();
public static ClusterResource noClusterId = new
ClusterResource("no_cluster_id");
public static AtomicReference<ClusterResource> clusterIdBeforeDeserialize
= new AtomicReference<>(noClusterId);
public boolean isKey;
public Map<String, ?> configs;
+ public boolean isClosed = false;
Review comment:
I revert all changes of ```MockDeserializer``` as the concern I
described is not existent yet.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
