# Note: This file is managed by Puppet.

#
# see kafka.consumer.ConsumerConfig for more details
#

# Zookeeper connection string
# comma separated host:port pairs, each corresponding to a zk
# server. e.g. "127.0.0.1:3000,127.0.0.1:3001,127.0.0.1:3002"
zookeeper.connect=<%= @zookeeper_hosts.sort.join(',') %><%= @zookeeper_chroot if @zookeeper_chroot %>

# timeout in ms for connecting to zookeeper
zookeeper.connection.timeout.ms=<%= @zookeeper_connection_timeout_ms %>

#consumer group id
group.id=<%= @consumer_group_id %>

#consumer timeout
#consumer.timeout.ms=5000