public static ObservableMetricsSystem init(final MetricsConfiguration metricsConfiguration) {
  if (!metricsConfiguration.isEnabled() && !metricsConfiguration.isPushEnabled()) {
    return new NoOpMetricsSystem();
  }
  final PrometheusMetricsSystem metricsSystem =
      new PrometheusMetricsSystem(
          metricsConfiguration.getMetricCategories(), metricsConfiguration.isTimersEnabled());
  if (metricsSystem.isCategoryEnabled(StandardMetricCategory.PROCESS)) {
    metricsSystem.collectors.put(
        StandardMetricCategory.PROCESS,
        singleton(new StandardExports().register(metricsSystem.registry)));
  }
  if (metricsSystem.isCategoryEnabled(StandardMetricCategory.JVM)) {
    metricsSystem.collectors.put(
        StandardMetricCategory.JVM,
        asList(
            new MemoryPoolsExports().register(metricsSystem.registry),
            new BufferPoolsExports().register(metricsSystem.registry),
            new GarbageCollectorExports().register(metricsSystem.registry),
            new ThreadExports().register(metricsSystem.registry),
            new ClassLoadingExports().register(metricsSystem.registry)));
  }
  return metricsSystem;
}
 

private void registerDefaultCollectors(CollectorRegistry registry) {
    // Add the JMX exporter for functionality similar to the kafka connect JMX metrics
    try {
        new JmxCollector("{}").register(registry);
    } catch (MalformedObjectNameException ex) {
        System.err.println(ex);
    }
    // Add the default exports from io.prometheus.client.hotspot.DefaultExports
    new StandardExports().register(registry);
    new MemoryPoolsExports().register(registry);
    new BufferPoolsExports().register(registry);
    new GarbageCollectorExports().register(registry);
    new ThreadExports().register(registry);
    new ClassLoadingExports().register(registry);
    new VersionInfoExports().register(registry);
}