rgroothuijsen commented on a change in pull request #9078:
URL: https://github.com/apache/kafka/pull/9078#discussion_r571647298
##########
File path:
clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java
##########
@@ -272,8 +272,16 @@ public MBeanInfo getMBeanInfo() {
for (Map.Entry<String, KafkaMetric> entry :
this.metrics.entrySet()) {
String attribute = entry.getKey();
KafkaMetric metric = entry.getValue();
+ String metricType = double.class.getName();
+
+ try {
+ metricType = metric.metricValue().getClass().getName();
+ } catch (NullPointerException e) {
Review comment:
@jeqo Thanks, moving the initialization did make a difference,
specifically after moving it past [this
point](https://github.com/apache/kafka/blob/8e211eb72f9a45897cc37fed394a38096aa47feb/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java#L232).
This did lead to an opposite problem, though, as now other exceptions start
appearing. From what I can tell, `WorkerGroupMember` and `HerderMetrics` are
dependent on each other, so I'm getting errors in one or the other when I
change the ordering around.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
