More constructors for KafkaClientMetrics

Author: sideeffffect

micrometer-core/src/main/java/io/micrometer/core/instrument/binder/kafka/KafkaClientMetrics.java

@@ -23,8 +23,11 @@
 import org.apache.kafka.clients.consumer.Consumer;
 import org.apache.kafka.clients.producer.Producer;
 import org.apache.kafka.common.Metric;
+import org.apache.kafka.common.MetricName;
 
+import java.util.Map;
 import java.util.concurrent.ScheduledExecutorService;
+import java.util.function.Supplier;
 
 /**
  * Kafka Client metrics binder. This should be closed on application shutdown to clean up
@@ -141,4 +144,31 @@ public KafkaClientMetrics(AdminClient adminClient) {
         super(adminClient::metrics);
     }
 
+
+    /**
+     * Kafka client metrics binder
+     * @param metricsSupplier supplier of metrics, make sure this comes from the Java Kafka Client because {@link KafkaClientMetrics} heavily depends on the behavior of the Java Kafka Client
+     */
+    public KafkaClientMetrics(Supplier<Map<MetricName, ? extends Metric>> metricsSupplier) {
+        super(metricsSupplier);
+    }
+
+    /**
+     * Kafka client metrics binder
+     * @param metricsSupplier supplier of metrics, make sure this comes from the Java Kafka Client because {@link KafkaClientMetrics} heavily depends on the behavior of the Java Kafka Client
+     * @param tags additional tags
+     */
+    public KafkaClientMetrics(Supplier<Map<MetricName, ? extends Metric>> metricsSupplier, Iterable<Tag> tags) {
+        super(metricsSupplier, tags);
+    }
+
+    /**
+     * Kafka client metrics binder
+     * @param metricsSupplier supplier of metrics, make sure this comes from the Java Kafka Client because {@link KafkaClientMetrics} heavily depends on the behavior of the Java Kafka Client
+     * @param tags additional tags
+     * @param scheduler custom scheduler to check and bind metrics
+     */
+    public KafkaClientMetrics(Supplier<Map<MetricName, ? extends Metric>> metricsSupplier, Iterable<Tag> tags, ScheduledExecutorService scheduler) {
+        super(metricsSupplier, tags, scheduler);
+    }
 }

micrometer-core/src/main/java/io/micrometer/core/instrument/binder/kafka/KafkaMetrics.java

@@ -56,7 +56,7 @@
 @Incubating(since = "1.4.0")
 @NonNullApi
 @NonNullFields
-public class KafkaMetrics implements MeterBinder, AutoCloseable {
+class KafkaMetrics implements MeterBinder, AutoCloseable {
 
     private static final InternalLogger log = InternalLoggerFactory.getInstance(KafkaMetrics.class);