storm-metrics-influxdb

Apache Storm IMetricsConsumer implementation for influxdb (> 0.9)

Installation

1. Clone this repo
2. Build the jar using maven : mvn package
3. Copy the built jar from target to storm lib directory : cp target/storm-metrics-influxdb*.jar $STORM_INSTALL_DIR/lib/
4. Restart your storm supervisors and workers

Configuration (storm.yaml)

topology.metrics.consumer.register:
  - class: "fr.boniface.storm.metrics.influxdb.InfluxDBMetricsConsumer"
    parallelism.hint: 1
    argument:
      metrics.reporter.name: "fr.boniface.storm.metrics.influxdb.InfluxDBMetricsConsumer"
      metrics.influxdb.url: "http://HOSTNAME:PORT"
      metrics.influxdb.username: "USERNAME"
      metrics.influxdb.password: "PASSWORD"
      metrics.influxdb.db: "DATABASE"
      metrics.influxdb.measurement.prefix: "PREFIX"