in src/main/java/org/apache/doris/kafka/connector/metrics/MetricsJmxReporter.java [63:82]
private static ObjectName getObjectName(
String connectorName, String jmxDomain, String metricName) {
try {
StringBuilder sb =
new StringBuilder(jmxDomain)
.append(":connector=")
.append(connectorName)
.append(',');
Iterator<String> tokens = Arrays.stream(StringUtils.split(metricName, "/")).iterator();
sb.append("task=").append(tokens.next());
sb.append(",category=").append(tokens.next());
sb.append(",name=").append(tokens.next());
return new ObjectName(sb.toString());
} catch (MalformedObjectNameException e) {
LOG.warn("Could not create Object name for MetricName:{}", metricName);
throw new DorisException("Object Name is invalid");
}
}