exe/kafkr-consumer in kafkr-0.5.7 vs exe/kafkr-consumer in kafkr-0.9.1

@@ -31,11 +31,11 @@
     handler_name = handler.class.name.split("::").last.gsub(/Handler$/, "")
     puts "#{handler_name} handler registered."
   end
 end
 
-def start_consumer(port,host)
+def start_consumer(port, host)
   puts "Starting consumer on port #{port}!"
   $handlers_changed = false
 
   Kafkr::Consumer.configure do |config|
     config.port = port
@@ -93,16 +93,16 @@
   end
 end
 
 file_checksums = {}
 monitoring_thread = Thread.new { monitor_handlers(file_checksums) }
-start_consumer(port,host)  # Pass the port here
+start_consumer(port, host)  # Pass the port here
 
 begin
   loop do
     if $restart_required
       stop_consumer
-      start_consumer(port,host)
+      start_consumer(port, host)
       $restart_required = false
     end
     sleep 1
   end
 rescue LoadError => e