I believe the *LoggingMetricsConsumer* [1] will do the job.

conf.registerMetricsConsumer(LoggingMetricsConsumer.class, 2);


Have a look at this tutorial [2].

[1]
https://github.com/nathanmarz/storm/blob/master/storm-core/src/jvm/backtype/storm/metric/LoggingMetricsConsumer.java
[2] https://www.endgame.com/blog/storm-metrics-how-to.html

2015-03-13 13:58 GMT+01:00 Nick R. Katsipoulakis <[email protected]>:

> Hello all,
>
> In Storm UI I can see the following metrics for each bolt/spout in an
> active topology: Capacity and Latency. Is there a way to get those metrics
> from the bolt's code and store them in a custom log file.
>
> Thank you,
> Nikos
>
>
> --
> Nikolaos Romanos Katsipoulakis,
> University of Pittsburgh, PhD candidate
>

Reply via email to