lib/racecar/ctl.rb in racecar-0.2.0 vs lib/racecar/ctl.rb in racecar-0.2.1

@@ -36,9 +36,17 @@
         end
       end
 
       parser.parse!(args)
 
+      if message.topic.nil?
+        raise Racecar::Error, "no topic specified"
+      end
+
+      if message.value.nil?
+        raise Racecar::Error, "no message value specified"
+      end
+
       ConfigLoader.load!
 
       Racecar.config.validate!
 
       kafka = Kafka.new(