@Override
    public void init(List<KafkaMetric> initMetrics) {
        synchronized (lock) {
            for (KafkaMetric metric : initMetrics) {
                log.debug("Adding metric {}", metric.metricName());
                metrics.put(metric.metricName(), metric);
            }
        }
    }
MetricsReporter that aggregates metrics data and reports it via HTTP requests to a configurable
webhook endpoint in JSON format.

This is an internal class used for system tests and does not provide any compatibility guarantees.
tools/src/main/java/org/apache/kafka/tools/PushHttpMetricsReporter.java