kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: KAFKA-5338: fix a miss-spell in ResetIntegrationTest
Date Mon, 29 May 2017 23:02:09 GMT
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 <he.jiefang@zte.com.cn>

Reviewers: Matthias J. Sax, Guozhang Wang

Closes #3159 from hejiefang/KAFKA-5338

(cherry picked from commit dc520d275adc715d56231fad771c66104e77ff3f)
Signed-off-by: Guozhang Wang <wangguoz@gmail.com>


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 <he.jiefang@zte.com.cn>
Authored: Mon May 29 16:01:54 2017 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
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,


Mime
View raw message