anchor.diff:              alias: kafka.request.produce.time.99percentile
       - include:
           domain: 'kafka.network'
  -        bean: 'kafka.network:type=RequestMetrics,name=TotalTimeMs,request=Fetch'
  -        attribute:
  -          Mean:
  -            metric_type: gauge
  -            alias: kafka.request.fetch.time.avg
  -          99thPercentile:
  -            metric_type: gauge
  -            alias: kafka.request.fetch.time.99percentile
  +        bean: 'kafka.network:type=RequestMetrics,name=RequestsPerSec,request=FetchConsumer'
  +        attribute:
  +          Count:
  +            metric_type: rate
  +            alias: kafka.request.fetch_consumer.rate
  +    - include:
  +        domain: 'kafka.network'
  +        bean: 'kafka.network:type=RequestMetrics,name=RequestsPerSec,request=FetchFollower'
  +        attribute:
  +          Count:
  +            metric_type: rate
  +            alias: kafka.request.fetch_follower.rate
  +    - include:
  +        domain: 'kafka.network'
  +        bean: 'kafka.network:type=RequestMetrics,name=TotalTimeMs,request=FetchConsumer'
  +        attribute:
  +          Mean:
  +            metric_type: gauge
  +            alias: kafka.request.fetch_consumer.time.avg
  +          99thPercentile:
  +            metric_type: gauge
  +            alias: kafka.request.fetch_consumer.time.99percentile
  +    - include:
  +        domain: 'kafka.network'
  +        bean: 'kafka.network:type=RequestMetrics,name=TotalTimeMs,request=FetchFollower'
  +        attribute:
  +          Mean:
  +            metric_type: gauge
  +            alias: kafka.request.fetch_follower.time.avg
  +          99thPercentile:
  +            metric_type: gauge
  +            alias: kafka.request.fetch_follower.time.99percentile
       - include:
           domain: 'kafka.network'
           bean: 'kafka.network:type=RequestMetrics,name=TotalTimeMs,request=UpdateMetadata'
  
positive.code: 
    # Metrics collected by this check. You should not have to modify this.
    conf:
      #
      # Aggregate cluster stats
      #
  
negative.code:         domain: 'kafka.server'
          bean: 'kafka.server:type=BrokerTopicMetrics,name=BytesOutPerSec'
          attribute:
            Count:
              metric_type: rate
              alias: kafka.net.bytes_out.rate
      - include:
          domain: 'kafka.server'
          bean: 'kafka.server:type=BrokerTopicMetrics,name=BytesInPerSec'
          attribute:
            Count:
              metric_type: rate
              alias: kafka.net.bytes_in.rate
      - include:
          domain: 'kafka.server'
          bean: 'kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec'
          attribute:
            Count:
              metric_type: rate
              alias: kafka.messages_in.rate
      - include:
          domain: 'kafka.server'
          bean: 'kafka.server:type=BrokerTopicMetrics,name=BytesRejectedPerSec'
          attribute:
            Count:
              metric_type: rate
              alias: kafka.net.bytes_rejected.rate
    <% node['masala_kafka']['topics_monitored'].each do |t| -%>
      - include:
          domain: 'kafka.server'
          bean: 'kafka.server:type=BrokerTopicMetrics,name=BytesInPerSec,topic=<%= t %>'
          attribute:
            Count:
              metric_type: rate
              alias: kafka.net.bytes_in.rate
     <% end -%>
  
      #
  