lib/jruby-kafka/group.rb in jruby-kafka-0.0.8 vs lib/jruby-kafka/group.rb in jruby-kafka-0.0.9
- old
+ new
@@ -52,10 +52,10 @@
@fetch_min_bytes = '1'
@fetch_wait_max_ms = '100'
@refresh_leader_backoff_ms = '200'
@consumer_timeout_ms = '-1'
@consumer_restart_on_error = "#{false}"
- @consumer_restart_sleep_ms = '2000'
+ @consumer_restart_sleep_ms = '0'
if options[:zk_connect_timeout]
@zk_connect_timeout = "#{options[:zk_connect_timeout]}"
end
if options[:zk_session_timeout]