samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vadim Chekan <kot.bege...@gmail.com>
Subject Re: Lag metric
Date Thu, 03 Mar 2016 02:57:15 GMT
Never mind, I forgot to "listen" to new metrics in my reporter, so those
metrics which were created immediately worked fine, and those which were
created later, for example when kafka metadata is fetched and count of
partitions is discovered, were ignored by my reporter.


On Wed, Mar 2, 2016 at 3:54 PM, Vadim Chekan <kot.begemot@gmail.com> wrote:

> Hi all,
>
> I want to report my task's kafka topic lag metric. I have implemented my
> own MetricReporterFactory to report to Influxdb. I can see that
> KafkaSystemConsumerMetrics class register "messages-behind-high-watermark"
> metric, but I can not trace where would it be registered with the reporter.
> I can see TaskInstanceMetrics, KafkaSystemProducerMetrics do register with
> my custom reporter but not KafkaSystemConsumerMetrics.
>
> Any hints?
> Vadym.
>
>
> --
> From RFC 2631: In ASN.1, EXPLICIT tagging is implicit unless IMPLICIT is
> explicitly specified
>



-- 
>From RFC 2631: In ASN.1, EXPLICIT tagging is implicit unless IMPLICIT is
explicitly specified

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message