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 <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 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); }