anchor.diff:  zookeeper.connect=<%= servers.join(',') %>
   
   # Timeout in ms for connecting to zookeeper
  -zookeeper.connection.timeout.ms=1000000
  +# zookeeper.connection.timeout.ms=1000000
  +
  +
  +###################### Production Settings #############################
  +
  +# Replication configurations
  +num.replica.fetchers=4
  +replica.fetch.max.bytes=1048576
  +replica.fetch.wait.max.ms=500
  +replica.high.watermark.checkpoint.interval.ms=5000
  +replica.socket.timeout.ms=30000
  +replica.socket.receive.buffer.bytes=65536
  +replica.lag.time.max.ms=10000
  +replica.lag.max.messages=4000
  +
  +controller.socket.timeout.ms=30000
  +controller.message.queue.size=10
  +
  +# Log configuration
  +num.partitions=8
  +message.max.bytes=1000000
  +auto.create.topics.enable=true
  +log.index.interval.bytes=4096
  +log.index.size.max.bytes=10485760
  +log.retention.hours=168
  +log.flush.interval.ms=10000
  +log.flush.interval.messages=20000
  +log.flush.scheduler.interval.ms=2000
  +log.roll.hours=168
  +log.retention.check.interval.ms=300000
  +log.segment.bytes=1073741824
  +
  +# ZK configuration
  +zookeeper.connection.timeout.ms=6000
  +zookeeper.sync.time.ms=2000
  +
  +# Socket server configuration
  +num.io.threads=8
  +num.network.threads=8
  +socket.request.max.bytes=104857600
  +socket.receive.buffer.bytes=1048576
  +socket.send.buffer.bytes=1048576
  +queued.max.requests=16
  +fetch.purgatory.purge.interval.requests=100
  +producer.purgatory.purge.interval.requests=100
  +
  
positive.code: # The default number of log partitions per topic. More partitions allow greater
  # parallelism for consumption, but this will also result in more files across
  # the brokers.
  num.partitions=2
  
  ############################# Log Flush Policy #############################
  
  
negative.code: # every N messages (or both). This can be done globally and overridden on a per-topic basis.
  
  # The number of messages to accept before forcing a flush of data to disk
  # log.flush.interval.messages=10000
  
  # The maximum amount of time a message can sit in a log before we force a flush
  # log.flush.interval.ms=1000
  
  ############################# Log Retention Policy #############################
  
  