Class LoggingMetricsConsumer

java.lang.Object
org.apache.storm.metric.LoggingMetricsConsumer
All Implemented Interfaces:
IMetricsConsumer

public class LoggingMetricsConsumer extends Object implements IMetricsConsumer
Listens for all metrics, dumps them to log

To use, add this to your topology's configuration:

```java conf.registerMetricsConsumer(org.apache.storm.metrics.LoggingMetricsConsumer.class, 1); ```

Or edit the storm.yaml config file:

```yaml topology.metrics.consumer.register: - class: "org.apache.storm.metrics.LoggingMetricsConsumer" parallelism.hint: 1 ```