exe/kafkr-consumer in kafkr-0.13.0 vs exe/kafkr-consumer in kafkr-0.18.0
- old
+ new
@@ -5,10 +5,10 @@
require "digest"
# Accepting command line arguments for host and port
host = ARGV[0] || "localhost"
port = ARGV[1] || 4000
-timeout = ARGV[2] || 120
+timeout = ARGV[2] || 300
puts "Running on host: #{host} and port: #{port}"
$current_consumer = nil
$restart_required = false