From dc520d275adc715d56231fad771c66104e77ff3f Mon Sep 17 00:00:00 2001 From: hejiefang Date: Mon, 29 May 2017 16:01:54 -0700 Subject: [PATCH] KAFKA-5338: fix a miss-spell in ResetIntegrationTest There is a Misspell in Annotations of ResetIntegrationTest. Author: hejiefang Reviewers: Matthias J. Sax, Guozhang Wang Closes #3159 from hejiefang/KAFKA-5338 --- .../apache/kafka/streams/integration/ResetIntegrationTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationTest.java index 31a146547f5..47a679eb635 100644 --- a/streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationTest.java @@ -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,