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