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