anchor.diff:  <% end %>
   
   <% unless node[:kafka][:version] == '0.8.0' %>
  -############################# Log Configuration #############################
  -
  -# this configuration must be set to true for log compaction to run.
  +############################# Log Cleaner Configuration #############################
  +
  +# This configuration must be set to true for log compaction to run.
   <%= render 'partials/option.erb', variables: {key: 'log.cleaner.enable', value: node[:kafka][:log][:cleaner_enable]} -%>
   
   # The number of threads to use for cleaning logs in log compaction.
  
positive.code: <%= render 'partials/option.erb', variables: {key: 'log.cleaner.enable', value: node[:kafka][:log][:cleaner_enable]} -%>
  <% end %>
  
  # the maximum size in bytes of the offset index
  <%= render 'partials/option.erb', variables: {key: 'log.index.size.max.bytes', value: node[:kafka][:log][:index_size_max_bytes]} -%>
  
  # the interval with which we add an entry to the offset index
  <%= render 'partials/option.erb', variables: {key: 'log.index.interval.bytes', value: node[:kafka][:log][:index_interval_bytes]} -%>
  
  # the number of messages accumulated on a log partition before messages are flushed to disk
  <%= render 'partials/option.erb', variables: {key: 'log.flush.interval.messages', value: node[:kafka][:log][:flush_interval_messages]} -%>
  
  # the maximum time in ms that a message in any topic is kept in memory before flushed to disk
  <%= render 'partials/option.erb', variables: {key: 'log.flush.interval.ms', value: node[:kafka][:log][:flush_interval_ms]} -%>
  
  <% if node[:kafka][:version] == '0.8.0' %>
  # the maximum time in ms that a message in selected topics is kept in memory before flushed to disk, e.g., topic1:3000,topic2:6000
  <%= render 'partials/hash_option.erb', variables: {key: 'log.flush.interval.ms.per.topic', value: node[:kafka][:log][:flush_interval_ms_per_topic]} -%>
  <% end %>
  
  # the frequency in ms that the log flusher checks whether any log needs to be flushed to disk
  <%= render 'partials/option.erb', variables: {key: 'log.flush.scheduler.interval.ms', value: node[:kafka][:log][:flush_scheduler_interval_ms]} -%>
  
  # enable auto creation of topic on the broker
  <%= render 'partials/option.erb', variables: {key: 'auto.create.topics.enable', value: node[:kafka][:auto_create_topics]} -%>
  
  <% unless node[:kafka][:version] == '0.8.0' %>
  
negative.code: <%= render 'partials/hash_option.erb', variables: {key: 'log.segment.bytes.per.topic', value: node[:kafka][:log][:segment_bytes_per_topic]} -%>
  <% end %>
  
  # The maximum time before a new log segment is rolled out
  <%= render 'partials/option.erb', variables: {key: 'log.roll.hours', value: node[:kafka][:log][:roll_hours]} -%>
  
  <% if node[:kafka][:version] == '0.8.0' %>
  # The number of hours before rolling out a new log segment for some specific topic
  <%= render 'partials/hash_option.erb', variables: {key: 'log.roll.hours.per.topic', value: node[:kafka][:log][:roll_hours_per_topic]} -%>
  
  # The number of hours to keep a log file before deleting it
  <%= render 'partials/option.erb', variables: {key: 'log.retention.hours', value: node[:kafka][:log][:retention_hours]} -%>
  
  # The number of hours to keep a log file before deleting it for some specific topic
  <%= render 'partials/hash_option.erb', variables: {key: 'log.retention.hours.per.topic', value: node[:kafka][:log][:retention_hours_per_topic]} -%>
  <% else %>
  # The number of hours to keep a log file before deleting it
  <%= render 'partials/option.erb', variables: {key: 'log.retention.minutes', value: node[:kafka][:log][:retention_minutes]} -%>
  <% end %>
  
  # The maximum size of the log before deleting it
  <%= render 'partials/option.erb', variables: {key: 'log.retention.bytes', value: node[:kafka][:log][:retention_bytes]} -%>
  
  <% if node[:kafka][:version] == '0.8.0' %>
  # The maximum size of the log for some specific topic before deleting it
  <%= render 'partials/hash_option.erb', variables: {key: 'log.retention.bytes.per.topic', value: node[:kafka][:log][:retention_bytes_per_topic]} -%>
  <% end %>
  
  <% if node[:kafka][:version] == '0.8.0' %>
  # The frequency in minutes that the log cleaner checks whether any log is eligible for deletion
  <%= render 'partials/option.erb', variables: {key: 'log.cleanup.interval.mins', value: node[:kafka][:log][:cleanup_interval_mins]} -%>
  <% else %>
  # The interval at which log segments are checked to see if they can be deleted according
  