diff --git a/conf/storm.yaml.example b/conf/storm.yaml.example index 1f1acaa3c..ac03051b9 100644 --- a/conf/storm.yaml.example +++ b/conf/storm.yaml.example @@ -24,7 +24,7 @@ ## Metrics Consumers # topology.metrics.consumer.register: -# - class: "backtype.storm.metrics.LoggingMetricsConsumer" +# - class: "backtype.storm.metric.LoggingMetricsConsumer" # parallelism.hint: 1 # - class: "org.mycompany.MyMetricsConsumer" # parallelism.hint: 1 diff --git a/storm-core/src/jvm/backtype/storm/metric/LoggingMetricsConsumer.java b/storm-core/src/jvm/backtype/storm/metric/LoggingMetricsConsumer.java index 2bff4ff97..9ff61609e 100644 --- a/storm-core/src/jvm/backtype/storm/metric/LoggingMetricsConsumer.java +++ b/storm-core/src/jvm/backtype/storm/metric/LoggingMetricsConsumer.java @@ -15,12 +15,12 @@ * Listens for all metrics, dumps them to log * * To use, add this to your topology's configuration: - * conf.registerMetricsConsumer(backtype.storm.metrics.LoggingMetricsConsumer.class, 1); + * conf.registerMetricsConsumer(backtype.storm.metric.LoggingMetricsConsumer.class, 1); * * Or edit the storm.yaml config file: * * topology.metrics.consumer.register: - * - class: "backtype.storm.metrics.LoggingMetricsConsumer" + * - class: "backtype.storm.metric.LoggingMetricsConsumer" * parallelism.hint: 1 * */