exe/kafkr-producer in kafkr-0.018.1 vs exe/kafkr-producer in kafkr-0.21.0
- old
+ new
@@ -1,12 +1,13 @@
#!/usr/bin/env ruby
+require "kafkr"
require "readline"
# Parsing command line arguments for host and port
host = ARGV[0] || "localhost"
port = ARGV[1] || 4000
-kakf "Running on host: #{host} and port: #{port}"
+Kafkr.log "Running on host: #{host} and port: #{port}"
begin
require "kafkr"
rescue LoadError => e
Kafkr.log "Failed to load Kafkr: #{e.message}"