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 2015/08/06 01:50:25 UTC
kafka git commit: MINOR: Fix typo in ReplicaVerificationTool output
Repository: kafka
Updated Branches:
refs/heads/trunk 907ee7b5e -> 9b1c52d52
MINOR: Fix typo in ReplicaVerificationTool output
Author: Andrew Otto <ac...@gmail.com>
Reviewers: Ismael Juma, Guozhang Wang
Closes #101 from ottomata/trunk and squashes the following commits:
10b76f3 [Andrew Otto] MINOR - Fix typo in ReplicaVerificationTool output
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/9b1c52d5
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/9b1c52d5
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/9b1c52d5
Branch: refs/heads/trunk
Commit: 9b1c52d52e4e9bbbd89b125fd510bf8b247643ac
Parents: 907ee7b
Author: Andrew Otto <ac...@gmail.com>
Authored: Wed Aug 5 16:51:25 2015 -0700
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Wed Aug 5 16:51:25 2015 -0700
----------------------------------------------------------------------
core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/9b1c52d5/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 1366172..fd9daec 100644
--- a/core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala
+++ b/core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala
@@ -92,7 +92,7 @@ object ReplicaVerificationTool extends Logging {
.describedAs("ms")
.ofType(classOf[java.lang.Long])
.defaultsTo(30 * 1000L)
-
+
if(args.length == 0)
CommandLineUtils.printUsageAndDie(parser, "Validate that all replicas for a set of topics have the same data.")
@@ -329,7 +329,7 @@ private class ReplicaBuffer(expectedReplicasPerTopicAndPartition: Map[TopicAndPa
if (currentTimeMs - lastReportTime > reportInterval) {
println(ReplicaVerificationTool.dateFormat.format(new Date(currentTimeMs)) + ": max lag is "
+ maxLag + " for partition " + maxLagTopicAndPartition + " at offset " + offsetWithMaxLag
- + " among " + messageSetCache.size + " paritions")
+ + " among " + messageSetCache.size + " partitions")
lastReportTime = currentTimeMs
}
}