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.bege...@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.bege...@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 >
