consumer.properties.erb
No OneTemporary
Actions

Size

831 B

Subscribers

None

consumer.properties.erb
View Options

	# 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 %>

	# The max time that the client waits while establishing a connection to Zookeeper.
	zookeeper.connection.timeout.ms=<%= @zookeeper_connection_timeout_ms %>

	# ZooKeeper session timeout. If the consumer fails to heartbeat to Zookeeper
	# for this period of time it is considered dead and a rebalance will occur.
	zookeeper.session.timeout.ms=<%= @zookeeper_session_timeout_ms %>

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

	#consumer timeout
	#consumer.timeout.ms=5000