You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository has been archived by the owner on Nov 20, 2019. It is now read-only.
The more I think about this the less convinced I am of one solution over another. Basically Verspaetung registers a ConsumerGauge with the internal MetricsRegistry and the getValue call will simply look up the latest values in the map of KafkaConsumer objects for that topic and TopicPartition objects for the latest metadata.
Since this all happens from within the getValue call we can't very well remove ourselves from the MetricsRegistrythere can we? We would also need to clean up the map with KafkaConsumer objects there too.
With consumer groups that were short-lived ephemeral consumer groups we should not attempt to report metrics on those up to the metrics provider.
This will prevent us from unnecessarily reporting metrics on consumers which haven't updated anything in, say, two weeks.
The text was updated successfully, but these errors were encountered: