private static ObjectName getObjectName()

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");
        }
    }