kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mj...@apache.org
Subject [kafka] branch 1.1 updated: MINOR: follow up cherry-pick KAFKA-6906
Date Mon, 11 Jun 2018 22:34:50 GMT
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 128d8ea  MINOR: follow up cherry-pick KAFKA-6906
128d8ea is described below

commit 128d8ea4f4023a5a9cf553d64588a512ff6dd45f
Author: Matthias J. Sax <matthias@confluent.io>
AuthorDate: Mon Jun 11 15:33:46 2018 -0700

    MINOR: follow up cherry-pick KAFKA-6906
---
 .../apache/kafka/streams/processor/internals/StreamTaskTest.java  | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java
b/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java
index 8cd53f9..9cf2e09 100644
--- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java
@@ -1034,7 +1034,7 @@ public class StreamTaskTest {
 
     @Test
     public void shouldThrowOnCleanCloseTaskWhenEosEnabledIfTransactionInFlight() {
-        task = createStatelessTask(createConfig(true));
+        task = createStatelessTask(true);
         try {
             task.close(true, false);
             fail("should have throw IllegalStateException");
@@ -1049,15 +1049,15 @@ public class StreamTaskTest {
     @Test
     public void shouldAlwaysCommitIfEosEnabled() {
         final RecordCollectorImpl recordCollector =  new RecordCollectorImpl(producer, "StreamTask",
-                new LogContext("StreamTaskTest "), new DefaultProductionExceptionHandler(),
new Metrics().sensor("skipped-records"));
+                new LogContext("StreamTaskTest "), new DefaultProductionExceptionHandler());
 
-        task = createStatelessTask(createConfig(true));
+        task = createStatelessTask(true);
         task.initializeStateStores();
         task.initializeTopology();
         task.punctuate(processorSystemTime, 5, PunctuationType.WALL_CLOCK_TIME, new Punctuator()
{
             @Override
             public void punctuate(final long timestamp) {
-                recordCollector.send("result-topic1", 3, 5, null, 0, time.milliseconds(),
+                recordCollector.send("result-topic1", 3, 5, 0, time.milliseconds(),
                         new IntegerSerializer(),  new IntegerSerializer());
             }
         });

-- 
To stop receiving notification emails like this one, please contact
mjsax@apache.org.

Mime
View raw message