Repository: kafka Updated Branches: refs/heads/trunk dfa3c8a92 -> dc520d275
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 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/dc520d27 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/dc520d27 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/dc520d27 Branch: refs/heads/trunk Commit: dc520d275adc715d56231fad771c66104e77ff3f Parents: dfa3c8a Author: hejiefang <[email protected]> Authored: Mon May 29 16:01:54 2017 -0700 Committer: Guozhang Wang <[email protected]> Committed: Mon May 29 16:01:54 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/dc520d27/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,
