Diamond is a python daemon that collects system metrics and publishes them to Graphite (and others). It is capable of collecting cpu, memory, network, i/o, load and disk metrics. Additionally, it features an API for implementing custom collectors for gathering metrics from almost any source.
Note that kafkastat collector requires MX4J configured, and there is an easier way to collect kafka metrics via JMX,which is enabled by default when starting kafka.
Note that kafkastat collector requires MX4J configured, and there is an easier way to collect kafka metrics via JMX,which is enabled by default when starting kafka.
You can go to confluent kafka monitoring to get metrics format