[kafka] branch 1.1 updated: MINOR: code cleanup TopologyTestDriverTest (#6504)

[mj...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a commit to branch 1.1
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/1.1 by this push:
     new cda00d0  MINOR: code cleanup TopologyTestDriverTest (#6504)
cda00d0 is described below

commit cda00d0e4a4731cb9a89fee9747c2f075a97c4c9
Author: Matthias J. Sax <mj...@apache.org>
AuthorDate: Wed Mar 27 11:26:27 2019 -0700

    MINOR: code cleanup TopologyTestDriverTest (#6504)
    
    Reviewers: Guozhang Wang <wa...@gmail.com>
---
 .../test/java/org/apache/kafka/streams/TopologyTestDriverTest.java    | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverTest.java b/streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverTest.java
index d3659a9..e874da1 100644
--- a/streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverTest.java
+++ b/streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverTest.java
@@ -46,6 +46,7 @@ import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.junit.runners.Parameterized;
 
+import java.time.Duration;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collection;
@@ -101,8 +102,6 @@ public class TopologyTestDriverTest {
         new StringSerializer(),
         new LongSerializer());
 
-    private final boolean eosEnabled;
-
     @Parameterized.Parameters(name = "Eos enabled = {0}")
     public static Collection<Object[]> data() {
         final List<Object[]> values = new ArrayList<>();
@@ -113,7 +112,6 @@ public class TopologyTestDriverTest {
     }
 
     public TopologyTestDriverTest(final boolean eosEnabled) {
-        this.eosEnabled = eosEnabled;
         if (eosEnabled) {
             config.put(StreamsConfig.PROCESSING_GUARANTEE_CONFIG, StreamsConfig.EXACTLY_ONCE);
         }