From 8068a3560b1896f25bdc664acd50d9c4d84f7baa Mon Sep 17 00:00:00 2001
From: Joel Dice <jdice@mersive.com>
Date: Wed, 12 Jul 2017 13:06:45 -0700
Subject: [PATCH] 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
---
 .../apache/kafka/streams/integration/EosIntegrationTest.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 c7f4ff4dcae..0c3b36aa84b 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()
                 );