This is a simple reporter for kafka using the GangliaReporter. It works with kafka 0.8 beta version.
- Build the
kafka-ganglia-1.0.0.jar
jar usingmvn package
. - Add
kafka-ganglia-1.0.0.jar
andmetrics-ganglia-2.2.0.jar
to thelibs/
directory of your kafka broker installation - Configure the broker (see the configuration section below)
- Restart the broker
Edit the server.properties
file of your installation, activate the reporter by setting:
kafka.metrics.reporters=com.criteo.kafka.KafkaGangliaMetricsReporter[,kafka.metrics.KafkaCSVMetricsReporter[,....]]
kafka.ganglia.metrics.reporter.enabled=true
Here is a list of default properties used:
kafka.ganglia.metrics.host=localhost
kafka.ganglia.metrics.port=8649
kafka.ganglia.metrics.group=kafka
# This can be use to exclude some metrics from ganglia
# since kafka has quite a lot of metrics, it is useful
# if you have many topics/partitions.
kafka.ganglia.metrics.exclude.regex=<not set>
Simply build the jar and publish it to your maven internal repository (this package is not published to any public repositories unfortunately).