Chesnay Schepler created FLINK-27487: ----------------------------------------
Summary: KafkaMetricWrappers do incorrect cast Key: FLINK-27487 URL: https://issues.apache.org/jira/browse/FLINK-27487 Project: Flink Issue Type: Bug Components: Connectors / Kafka, Runtime / Metrics Affects Versions: 1.15.0 Reporter: Chesnay Schepler Fix For: 1.16.0, 1.15.1 In FLINK-24765 the kafka metric wrappers that bridge kafka metrics into our metric system were migrated from the deprecated {{KafkaMetric#value}} to {{#metricValue}}. This migration was done incorrectly. It was assumed that #metricValue behaves similar to #value in that it always returns a double, but this is not the case, as they may also return longs or strings. -- This message was sent by Atlassian Jira (v8.20.7#820007)