This is an automated email from the ASF dual-hosted git repository. mjsax pushed a commit to branch 2.0 in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.0 by this push: new 0a85004 MINOR: code cleanup TopologyTestDriverTest (#6504) 0a85004 is described below commit 0a850049ef2580608ddf720c2896cb13852ea33d Author: Matthias J. Sax <mj...@apache.org> AuthorDate: Wed Mar 27 11:26:27 2019 -0700 MINOR: code cleanup TopologyTestDriverTest (#6504) Reviewers: Guozhang Wang <wangg...@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 b32226c..4182ade 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 @@ -53,6 +53,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.Collection; import java.util.Collections; @@ -112,8 +113,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<>(); @@ -124,7 +123,6 @@ public class TopologyTestDriverTest { } public TopologyTestDriverTest(final boolean eosEnabled) { - this.eosEnabled = eosEnabled; if (eosEnabled) { config.put(StreamsConfig.PROCESSING_GUARANTEE_CONFIG, StreamsConfig.EXACTLY_ONCE); }