Versions Compared

Old Version 4

changes.mady.by.user Charly Molter

Saved on

compared with

New Version 5

changes.mady.by.user Charly Molter

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Sensors will still be removed/added on assignment change to avoid reporting metrics for partitions we are not handling anymore.

 

This will enable people to do:

Code Block
languagejava
linenumberstrue
Map<String, String> tags = new HashMap<>();
tags.put("client-id", "<client-id>")
tags.put("topic", "<topic>")
tags.put("partition", "<partition>")
consumer.metrics().get(Metrics.metricName("records-lag", "consumer-fetch-manager-metrics", tags));

rather than:

Code Block
languagejava
linenumberstrue
Map<String, String> tags = Collections.singletonMap("client-id", "<client-id>");
consumer.metrics().get(Metrics.metricName(String.format("%s.records-lag", new TopicPartition("<topic>", <partition>)), "consumer-fetch-manager-metrics", tags));

The new options is more standard with the rest of the existing metrics.

Compatibility, Deprecation, and Migration Plan

...