lib/jruby-kafka/group.rb in jruby-kafka-0.0.4 vs lib/jruby-kafka/group.rb in jruby-kafka-0.0.5
- old
+ new
@@ -44,11 +44,11 @@
@rebalance_max_retries = '4'
@rebalance_backoff_ms = '2000'
@socket_timeout_ms = "#{30 * 1000}"
@socket_receive_buffer_bytes = "#{64 * 1024}"
@fetch_message_max_bytes = "#{1024 * 1024}"
- @auto_commit_enable = true
+ @auto_commit_enable = "#{true}"
@queued_max_message_chunks = '10'
@fetch_min_bytes = '1'
@fetch_wait_max_ms = '100'
@refresh_leader_backoff_ms = '200'
@consumer_timeout_ms = '-1'
@@ -85,10 +85,10 @@
if options[:fetch_message_max_bytes]
@fetch_message_max_bytes = options[:fetch_message_max_bytes]
end
if options[:auto_commit_enable]
- @auto_commit_enable = options[:auto_commit_enable]
+ @auto_commit_enable = "#{options[:auto_commit_enable]}"
end
if options[:queued_max_message_chunks]
@queued_max_message_chunks = options[:queued_max_message_chunks]
end