You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2019/04/17 00:14:28 UTC
[kafka] branch 2.0 updated: MINOR: code cleanup
TopologyTestDriverTest (#6504)
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 <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 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);
}