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
> wrote:
>
> > Hi all,
> >
> > I want to report my task&
2016 at 3:54 PM, Vadim Chekan 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&q
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
