Browse Source

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
pull/3522/merge
Joel Dice 7 years ago committed by Damian Guy
parent
commit
8068a3560b
  1. 2
      streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java

2
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)); put(ConsumerConfig.ISOLATION_LEVEL_CONFIG, IsolationLevel.READ_COMMITTED.name().toLowerCase(Locale.ROOT));
} }
}), }),
inputTopic, outputTopic,
inputData.size() inputData.size()
); );

Loading…
Cancel
Save