diff --git a/examples/src/main/scala/org/apache/spark/streaming/examples/KafkaWordCount.scala b/examples/src/main/scala/org/apache/spark/streaming/examples/KafkaWordCount.scala
index 3a18bd02b89acb8c7a541dc7e0c68052f0612a6a..2aa4f1474a59e904b7d7e2c763f68cddc2aba438 100644
--- a/examples/src/main/scala/org/apache/spark/streaming/examples/KafkaWordCount.scala
+++ b/examples/src/main/scala/org/apache/spark/streaming/examples/KafkaWordCount.scala
@@ -71,7 +71,7 @@ object KafkaWordCount {
 object KafkaWordCountProducer {
 
   def main(args: Array[String]) {
-    if (args.length < 2) {
+    if (args.length < 4) {
       System.err.println("Usage: KafkaWordCountProducer <metadataBrokerList> <topic> " +
         "<messagesPerSec> <wordsPerMessage>")
       System.exit(1)