samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yi Pan <nickpa...@gmail.com>
Subject Re: Lag metric
Date Thu, 03 Mar 2016 22:08:51 GMT
Hi, Vadim,

Glad that you figured out. Please let us know if you have further questions.

-Yi

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

> 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