Browse Source

KAFKA-5338: fix a miss-spell in ResetIntegrationTest

There is a Misspell in Annotations of ResetIntegrationTest.

Author: hejiefang <he.jiefang@zte.com.cn>

Reviewers: Matthias J. Sax, Guozhang Wang

Closes #3159 from hejiefang/KAFKA-5338
pull/3079/merge
hejiefang 8 years ago committed by Guozhang Wang
parent
commit
dc520d275a
  1. 2
      streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationTest.java

2
streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationTest.java

@ -158,7 +158,7 @@ public class ResetIntegrationTest { @@ -158,7 +158,7 @@ public class ResetIntegrationTest {
TestUtils.waitForCondition(consumerGroupInactive, TIMEOUT_MULTIPLIER * STREAMS_CONSUMER_TIMEOUT,
"Streams Application consumer group did not time out after " + (TIMEOUT_MULTIPLIER * STREAMS_CONSUMER_TIMEOUT) + " ms.");
// insert bad record to maks sure intermediate user topic gets seekToEnd()
// insert bad record to make sure intermediate user topic gets seekToEnd()
mockTime.sleep(1);
IntegrationTestUtils.produceKeyValuesSynchronouslyWithTimestamp(
INTERMEDIATE_USER_TOPIC,

Loading…
Cancel
Save