@Override
    public void close() {
        executor.shutdown();
        try {
            executor.awaitTermination(30, TimeUnit.SECONDS);
        } catch (InterruptedException e) {
            throw new KafkaException("Interrupted when shutting down PushHttpMetricsReporter", e);
        }
    }
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