[GitHub] [kafka] vvcephei commented on a change in pull request #8541: KAFKA-6145: KIP-441: Add TaskAssignor class config

[GitBox]

vvcephei commented on a change in pull request #8541:
URL: https://github.com/apache/kafka/pull/8541#discussion_r414654696



##########
File path: 
streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
##########
@@ -111,8 +115,9 @@
     private final String storeName = "store";
 
     private AtomicBoolean errorInjected;
-    private AtomicBoolean gcInjected;
-    private volatile boolean doGC = true;
+    private AtomicBoolean stallInjected;

Review comment:
       This is another case where I've gotten tripped up by the same thing 
twice, and decided to fix it this time.




----------------------------------------------------------------
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