kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From damian...@apache.org
Subject kafka git commit: MINOR: consume from outputTopic in EosIntegrationTest.runSimpleCopyTest
Date Wed, 12 Jul 2017 20:07:03 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.11.0 dbf83c28e -> 07bd39467


MINOR: consume from outputTopic in EosIntegrationTest.runSimpleCopyTest

Previously, the code mistakenly consumed from inputTopic, which
worked, but didn't actually verify that the messages were correctly
copied from inputTopic to outputTopic.

Author: Joel Dice <jdice@mersive.com>

Reviewers: Matthias J. Sax <matthias@confluent.io>, Damian Guy <damian.guy@gmail.com>

Closes #3522 from dicej/trunk

(cherry picked from commit 8068a3560b1896f25bdc664acd50d9c4d84f7baa)
Signed-off-by: Damian Guy <damian.guy@gmail.com>


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/07bd3946
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/07bd3946
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/07bd3946

Branch: refs/heads/0.11.0
Commit: 07bd394676de9fbeac11f88fe8fc8604689f47db
Parents: dbf83c2
Author: Joel Dice <jdice@mersive.com>
Authored: Wed Jul 12 13:06:45 2017 -0700
Committer: Damian Guy <damian.guy@gmail.com>
Committed: Wed Jul 12 13:06:56 2017 -0700

----------------------------------------------------------------------
 .../org/apache/kafka/streams/integration/EosIntegrationTest.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/07bd3946/streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
----------------------------------------------------------------------
diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
b/streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
index c7f4ff4..0c3b36a 100644
--- a/streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
@@ -192,7 +192,7 @@ public class EosIntegrationTest {
                                 put(ConsumerConfig.ISOLATION_LEVEL_CONFIG, IsolationLevel.READ_COMMITTED.name().toLowerCase(Locale.ROOT));
                             }
                         }),
-                    inputTopic,
+                    outputTopic,
                     inputData.size()
                 );
 


Mime
View raw message