Repository: kafka Updated Branches: refs/heads/0.11.0 569248f6f -> a1da4c534
KAFKA-5338: fix a miss-spell in ResetIntegrationTest There is a Misspell in Annotations of ResetIntegrationTest. Author: hejiefang <[email protected]> Reviewers: Matthias J. Sax, Guozhang Wang Closes #3159 from hejiefang/KAFKA-5338 (cherry picked from commit dc520d275adc715d56231fad771c66104e77ff3f) Signed-off-by: Guozhang Wang <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/a1da4c53 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/a1da4c53 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/a1da4c53 Branch: refs/heads/0.11.0 Commit: a1da4c5345ce0815104028699b751b90d0bbd104 Parents: 569248f Author: hejiefang <[email protected]> Authored: Mon May 29 16:01:54 2017 -0700 Committer: Guozhang Wang <[email protected]> Committed: Mon May 29 16:02:05 2017 -0700 ---------------------------------------------------------------------- .../org/apache/kafka/streams/integration/ResetIntegrationTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/a1da4c53/streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationTest.java ---------------------------------------------------------------------- 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 31a1465..47a679e 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,
