anchor.diff:                          #InstanceFrom ""
                           Table false
                           Attribute "AsyncProducerQueueSize"
  +                </Value>
  +        </MBean>
  +        <MBean "hits-accepted">
  +                ObjectName "logreplayer:type=logconsumer,name=hits-accepted"
  +                #InstancePrefix ""
  +                InstanceFrom "name"
  +                <Value>
  +                        Type "counter"
  +                        InstancePrefix "Count"
  +                        #InstanceFrom ""
  +                        Table false
  +                        Attribute "Count"
  +                </Value>
  +                <Value>
  +                        Type "gauge"
  +                        InstancePrefix "MeanRate"
  +                        #InstanceFrom ""
  +                        Table false
  +                        Attribute "MeanRate"
  +                </Value>
  +        </MBean>
  +        <MBean "hits-per-log-file">
  +                ObjectName "logreplayer:type=logconsumer,name=hits-per-log-file"
  +                #InstancePrefix ""
  +                InstanceFrom "name"
  +                <Value>
  +                        Type "counter"
  +                        InstancePrefix "Count"
  +                        #InstanceFrom ""
  +                        Table false
  +                        Attribute "Count"
  +                </Value>
  +                <Value>
  +                        Type "gauge"
  +                        InstancePrefix "Max"
  +                        #InstanceFrom ""
  +                        Table false
  +                        Attribute "Max"
  +                </Value>
  +                <Value>
  +                        Type "gauge"
  +                        InstancePrefix "Mean"
  +                        #InstanceFrom ""
  +                        Table false
  +                        Attribute "Mean"
  +                </Value>
  +                <Value>
  +                        Type "gauge"
  +                        InstancePrefix "Min"
  +                        #InstanceFrom ""
  +                        Table false
  +                        Attribute "Min"
  +                </Value>
  +        </MBean>
  +       <MBean "log-files-replayed">
  +                ObjectName "logreplayer:type=logconsumer,name=log-files-replayed"
  +                #InstancePrefix ""
  +                InstanceFrom "name"
  +                <Value>
  +                        Type "counter"
  +                        InstancePrefix "Count"
  +                        #InstanceFrom ""
  +                        Table false
  +                        Attribute "Count"
  +                </Value>
  +                <Value>
  +                        Type "gauge"
  +                        InstancePrefix "MeanRate"
  +                        #InstanceFrom ""
  +                        Table false
  +                        Attribute "MeanRate"
                   </Value>
           </MBean>
           #####################
  
positive.code:         #####################
          #Connection Block
          <Connection>
                  Host "<%= @node[:hostname] %>"
                  ServiceURL "service:jmx:rmi:///jndi/rmi://localhost:9999/jmxrmi"
                  Collect "kafka"
                  Collect "async"
          </Connection>
          </Plugin>
  </Plugin>
  
negative.code:         ################
          # MBean blocks #
          ################
  		# Memory usage by memory pool.
  		<MBean "memory_pool">
  			ObjectName "java.lang:type=MemoryPool,*"
  			InstancePrefix "memory_pool-"
  			InstanceFrom "name"
  			<Value>
  				Type "memory"
  				#InstancePrefix ""
  				#InstanceFrom ""
  				Table true
  				Attribute "Usage"
  			</Value>
  		</MBean>	
  		# Heap memory usage
  		<MBean "memory-heap">
  			ObjectName "java.lang:type=Memory"
  			#InstanceFrom ""
  			InstancePrefix "memory-heap"  
  			# Creates four values: committed, init, max, used
  			<Value>
  				Type "memory"  
  				#InstancePrefix ""
  				#InstanceFrom ""
  				Table true
  				Attribute "HeapMemoryUsage"
  			</Value>
  		</MBean>
  		# Non-heap memory usage
  		<MBean "memory_nonheap">
  			ObjectName "java.lang:type=Memory"
  			#InstanceFrom ""
  			InstancePrefix "memory-nonheap"
  			# Creates four values: committed, init, max, used
  			<Value>
  				Type "memory"
  				#InstancePrefix ""
  				#InstanceFrom ""
  				Table true
  				Attribute "NonHeapMemoryUsage"
  			</Value>
  		</MBean>
  		# Non-heap memory usage
  		<MBean "java_threads">
  			ObjectName "java.lang:type=Threading"
  			#InstanceFrom ""
  			InstancePrefix "java_threads"
  			<Value>
  				Type "gauge"
  				InstancePrefix "ThreadCount"
  				#InstanceFrom ""
  				Attribute "ThreadCount"
  			</Value>
  		</MBean>	
  		# Garbage Collector stats
  		<MBean "garbage_collector">
  			ObjectName "java.lang:type=GarbageCollector,*"
  			InstancePrefix "gc-"
  			InstanceFrom "name"
  			<Value>
  				Type "invocations"
  				InstancePrefix "collection_count"
  				#InstanceFrom ""
  				Table false
  				Attribute "CollectionCount"
  			</Value>
  			<Value>
  				Type "total_time_in_ms"
  				InstancePrefix "collection_time"
  				#InstanceFrom ""
  				Table false
  				Attribute "CollectionTime"
  			</Value>
  		</MBean>
  		# Number of classes being loaded.
  		<MBean "classes">
  			ObjectName "java.lang:type=ClassLoading"
  			InstancePrefix "loaded_classes"
  			#InstanceFrom ""
  			<Value>
  				Type "gauge"
  				InstancePrefix "loaded_classes"
  				#InstanceFrom ""
  				Table false
  				Attribute "LoadedClassCount"
  			</Value>
  		</MBean>
  		#Kafka Metrics
          <MBean "kafka">
                  ObjectName "kafka:type=kafka.KafkaProducerStats"
                  InstancePrefix "KafkaProducerStats"
  