exe/kafkr-producer in kafkr-0.18.0 vs exe/kafkr-producer in kafkr-0.018.1

- old
+ new

@@ -3,16 +3,16 @@ # Parsing command line arguments for host and port host = ARGV[0] || "localhost" port = ARGV[1] || 4000 -puts "Running on host: #{host} and port: #{port}" +kakf "Running on host: #{host} and port: #{port}" begin require "kafkr" rescue LoadError => e - puts "Failed to load Kafkr: #{e.message}" + Kafkr.log "Failed to load Kafkr: #{e.message}" exit(1) end begin Kafkr::Producer.configure do |config| @@ -22,17 +22,17 @@ while line = Readline.readline("> ", true) break if line == "exit" if line.include? "<=>" - puts Kafkr::Producer.send_message_and_wait(line) + Kafkr.log Kafkr::Producer.send_message_and_wait(line) else Kafkr::Producer.send_message(line) end end rescue => e - puts "An error occurred: #{e.message}" + Kafkr.log "An error occurred: #{e.message}" exit(1) rescue Interrupt - puts "\nProducer server shutting down gracefully..." + Kafkr.log "\nProducer server shutting down gracefully..." exit(0) end