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-5088: some spelling error in code comment
Date Fri, 21 Apr 2017 04:43:11 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk f18a14af3 -> fc5ad22e3


KAFKA-5088: some spelling error in code comment

fix some spelling errors

Author: xinlihua <xin.lihua1@zte.com.cn>

Reviewers: Matthias J. Sax, Guozhang Wang

Closes #2871 from auroraxlh/fix_spellingerror


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/fc5ad22e
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/fc5ad22e
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/fc5ad22e

Branch: refs/heads/trunk
Commit: fc5ad22e33cb9f757f645cec9d4afe9e65292712
Parents: f18a14a
Author: Lihua Xin <xin.lihua1@zte.com.cn>
Authored: Thu Apr 20 21:43:08 2017 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Thu Apr 20 21:43:08 2017 -0700

----------------------------------------------------------------------
 core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala      | 2 +-
 core/src/main/scala/kafka/tools/SimpleConsumerShell.scala          | 2 +-
 .../kafka/streams/integration/utils/IntegrationTestUtils.java      | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/fc5ad22e/core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala b/core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala
index c9c2e44..e765f41 100644
--- a/core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala
+++ b/core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala
@@ -118,7 +118,7 @@ object ReplicaVerificationTool extends Logging {
     val initialOffsetTime = options.valueOf(initialOffsetTimeOpt).longValue
     val reportInterval = options.valueOf(reportIntervalOpt).longValue
     // getting topic metadata
-    info("Getting topic metatdata...")
+    info("Getting topic metadata...")
     val brokerList = options.valueOf(brokerListOpt)
     ToolsUtils.validatePortOrDie(parser,brokerList)
     val metadataTargetBrokers = ClientUtils.parseBrokerList(brokerList)

http://git-wip-us.apache.org/repos/asf/kafka/blob/fc5ad22e/core/src/main/scala/kafka/tools/SimpleConsumerShell.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/tools/SimpleConsumerShell.scala b/core/src/main/scala/kafka/tools/SimpleConsumerShell.scala
index 586fdf2..c098bbd 100755
--- a/core/src/main/scala/kafka/tools/SimpleConsumerShell.scala
+++ b/core/src/main/scala/kafka/tools/SimpleConsumerShell.scala
@@ -126,7 +126,7 @@ object SimpleConsumerShell extends Logging {
                        .minBytes(ConsumerConfig.MinFetchBytes)
 
     // getting topic metadata
-    info("Getting topic metatdata...")
+    info("Getting topic metadata...")
     val brokerList = options.valueOf(brokerListOpt)
     ToolsUtils.validatePortOrDie(parser,brokerList)
     val metadataTargetBrokers = ClientUtils.parseBrokerList(brokerList)

http://git-wip-us.apache.org/repos/asf/kafka/blob/fc5ad22e/streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java
----------------------------------------------------------------------
diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java
b/streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java
index c31647c..3c52e19 100644
--- a/streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java
+++ b/streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java
@@ -284,7 +284,7 @@ public class IntegrationTestUtils {
                 }
                 return true;
             }
-        }, timeout, "metatadata for topic=" + topic + " partition=" + partition + " not propogated
to all brokers");
+        }, timeout, "metadata for topic=" + topic + " partition=" + partition + " not propagated
to all brokers");
 
     }
 }


Mime
View raw message