You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2017/04/21 04:43:11 UTC
kafka git commit: KAFKA-5088: some spelling error in code comment
Repository: kafka
Updated Branches:
refs/heads/trunk f18a14af3 -> fc5ad22e3
KAFKA-5088: some spelling error in code comment
fix some spelling errors
Author: xinlihua <xi...@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 <xi...@zte.com.cn>
Authored: Thu Apr 20 21:43:08 2017 -0700
Committer: Guozhang Wang <wa...@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");
}
}