diff --git a/core/src/main/scala/kafka/tools/DumpLogSegments.scala b/core/src/main/scala/kafka/tools/DumpLogSegments.scala
index 31333e7..29bae8c 100644
--- a/core/src/main/scala/kafka/tools/DumpLogSegments.scala
+++ b/core/src/main/scala/kafka/tools/DumpLogSegments.scala
@@ -30,13 +30,13 @@ object DumpLogSegments {
   def main(args: Array[String]) {
     val parser = new OptionParser
     val printOpt = parser.accepts("print-data-log", "if set, printing the messages content when dumping data logs")
-                           .withOptionalArg
+                           .withRequiredArg
                            .describedAs("print data log content")
                            .ofType(classOf[java.lang.Boolean])
                            .defaultsTo(false)
 
     val verifyOpt = parser.accepts("verify-index-only", "if set, just verify the index log without printing its content")
-                           .withOptionalArg
+                           .withRequiredArg
                            .describedAs("just verify the index log")
                            .ofType(classOf[java.lang.Boolean])
                            .defaultsTo(false)
diff --git a/core/src/main/scala/kafka/tools/JmxTool.scala b/core/src/main/scala/kafka/tools/JmxTool.scala
index 4bfac53..7e424e7 100644
--- a/core/src/main/scala/kafka/tools/JmxTool.scala
+++ b/core/src/main/scala/kafka/tools/JmxTool.scala
@@ -43,7 +43,7 @@ object JmxTool extends Logging {
     val attributesOpt =
       parser.accepts("attributes", "The whitelist of attributes to query. This is a comma-separated list. If no " +
         "attributes are specified all objects will be queried.")
-        .withOptionalArg()
+        .withRequiredArg
         .describedAs("name")
         .ofType(classOf[String])
     val reportingIntervalOpt = parser.accepts("reporting-interval", "Interval in MS with which to poll jmx stats.")
@@ -54,7 +54,7 @@ object JmxTool extends Logging {
     val helpOpt = parser.accepts("help", "Print usage information.")
     val dateFormatOpt = parser.accepts("date-format", "The date format to use for formatting the time field. " +
       "See java.text.SimpleDateFormat for options.")
-      .withOptionalArg()
+      .withRequiredArg
       .describedAs("format")
       .ofType(classOf[String])
     val jmxServiceUrlOpt =
diff --git a/core/src/main/scala/kafka/tools/SimpleConsumerShell.scala b/core/src/main/scala/kafka/tools/SimpleConsumerShell.scala
index d8127a8..ddceece 100644
--- a/core/src/main/scala/kafka/tools/SimpleConsumerShell.scala
+++ b/core/src/main/scala/kafka/tools/SimpleConsumerShell.scala
@@ -54,12 +54,12 @@ object SimpleConsumerShell extends Logging {
                            .ofType(classOf[java.lang.Integer])
                            .defaultsTo(UseLeaderReplica)
     val offsetOpt = parser.accepts("offset", "The offset id to consume from, default to -2 which means from beginning; while value -1 means from end")
-                           .withOptionalArg()
+                           .withRequiredArg
                            .describedAs("consume offset")
                            .ofType(classOf[java.lang.Long])
                            .defaultsTo(OffsetRequest.EarliestTime)
     val clientIdOpt = parser.accepts("clientId", "The ID of this client.")
-                           .withOptionalArg
+                           .withRequiredArg
                            .describedAs("clientId")
                            .ofType(classOf[String])
                            .defaultsTo("SimpleConsumerShell")
@@ -78,7 +78,7 @@ object SimpleConsumerShell extends Logging {
                            .describedAs("prop")
                            .ofType(classOf[String])
     val printOffsetOpt = parser.accepts("print-offsets", "Print the offsets returned by the iterator")
-                           .withOptionalArg
+                           .withRequiredArg
                            .describedAs("print offsets")
                            .ofType(classOf[java.lang.Boolean])
                            .defaultsTo(false)
diff --git a/perf/src/main/scala/kafka/perf/SimpleConsumerPerformance.scala b/perf/src/main/scala/kafka/perf/SimpleConsumerPerformance.scala
index 9c9eead..c52ada0 100644
--- a/perf/src/main/scala/kafka/perf/SimpleConsumerPerformance.scala
+++ b/perf/src/main/scala/kafka/perf/SimpleConsumerPerformance.scala
@@ -134,7 +134,7 @@ object SimpleConsumerPerformance {
                            .ofType(classOf[java.lang.Integer])
                            .defaultsTo(1024*1024)
     val clientIdOpt = parser.accepts("clientId", "The ID of this client.")
-                           .withOptionalArg
+                           .withRequiredArg
                            .describedAs("clientId")
                            .ofType(classOf[String])
                            .defaultsTo("SimpleConsumerPerformanceClient")