kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject kafka git commit: kafka-1517; Messages is a required argument to Producer Performance Test; patched by Daniel Compton; reviewed by Jun Rao
Date Wed, 08 Apr 2015 05:19:06 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 06a26656f -> fef709d51


kafka-1517; Messages is a required argument to Producer Performance Test; patched by Daniel
Compton; reviewed by Jun Rao


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

Branch: refs/heads/trunk
Commit: fef709d51ae3d568c6b6a9ff41a16f1969d4ffd6
Parents: 06a2665
Author: Daniel Compton <desk@danielcompton.net>
Authored: Tue Apr 7 22:18:56 2015 -0700
Committer: Jun Rao <junrao@gmail.com>
Committed: Tue Apr 7 22:18:56 2015 -0700

----------------------------------------------------------------------
 core/src/main/scala/kafka/tools/PerfConfig.scala | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/fef709d5/core/src/main/scala/kafka/tools/PerfConfig.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/tools/PerfConfig.scala b/core/src/main/scala/kafka/tools/PerfConfig.scala
index d073acf..298bb29 100644
--- a/core/src/main/scala/kafka/tools/PerfConfig.scala
+++ b/core/src/main/scala/kafka/tools/PerfConfig.scala
@@ -22,11 +22,10 @@ import joptsimple.OptionParser
 
 class PerfConfig(args: Array[String]) {
   val parser = new OptionParser
-  val numMessagesOpt = parser.accepts("messages", "The number of messages to send or consume")
+  val numMessagesOpt = parser.accepts("messages", "REQUIRED: The number of messages to send
or consume")
     .withRequiredArg
     .describedAs("count")
     .ofType(classOf[java.lang.Long])
-    .defaultsTo(Long.MaxValue)
   val reportingIntervalOpt = parser.accepts("reporting-interval", "Interval at which to print
progress info.")
     .withRequiredArg
     .describedAs("size")


Mime
View raw message