This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.1 in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.1 by this push: new 10d1fde MINOR: code cleanup TopologyTestDriverTest (#6504) 10d1fde is described below commit 10d1fdeaabcd4018b4e33a2096fdce71041c830f 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 | 5 +---- 1 file changed, 1 insertion(+), 4 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 e01e739..062e51d 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 @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams; -import java.time.Duration; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.clients.producer.ProducerRecord; import org.apache.kafka.common.header.Header; @@ -54,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.Arrays; import java.util.Collection; @@ -114,8 +114,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<>(); @@ -126,7 +124,6 @@ public class TopologyTestDriverTest { } public TopologyTestDriverTest(final boolean eosEnabled) { - this.eosEnabled = eosEnabled; if (eosEnabled) { config.put(StreamsConfig.PROCESSING_GUARANTEE_CONFIG, StreamsConfig.EXACTLY_ONCE); }