Hi all,

I want to monitor the max lag of a kafka streams job which is consuming from 
three topics and to do that I have implemented the MetricsReporter interface 
which I pass through the Streams Configuration to the KafkaStreams object. In 
the implementation’s metricChange()  method I have logging for the metric with 
group consumer-fetch-manager-metrics and name records-lag-max. However, the 
implementation never receives a metricChange notification for 'records-lag-max’.

I would like to know if what I am doing makes sense, is the correct approach 
and whether the implementation should be getting notifications for 
'records-lag-max’ periodically or only when the max lag is changing i.e. 
Increasing/decreasing.

Thanks,
Rohit


________________________________

This email and any attachments may contain confidential and privileged material 
for the sole use of the intended recipient. Any review, copying, or 
distribution of this email (or any attachments) by others is prohibited. If you 
are not the intended recipient, please contact the sender immediately and 
permanently delete this email and any attachments. No employee or agent of TiVo 
Inc. is authorized to conclude any binding agreement on behalf of TiVo Inc. by 
email. Binding agreements with TiVo Inc. may only be made by a signed written 
agreement.

Reply via email to