diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderMetrics.java b/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderMetrics.java index f5308b63b..6c15693ed 100644 --- a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderMetrics.java +++ b/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderMetrics.java @@ -22,9 +22,7 @@ import java.util.List; import java.util.Map; import java.util.concurrent.TimeUnit; -import io.micrometer.core.instrument.Gauge; import io.micrometer.core.instrument.MeterRegistry; -import io.micrometer.core.instrument.Tags; import io.micrometer.core.instrument.TimeGauge; import io.micrometer.core.instrument.binder.MeterBinder; import org.apache.commons.logging.Log; @@ -51,6 +49,7 @@ import org.springframework.util.ObjectUtils; * @author Soby Chacko * @author Artem Bilan * @author Oleg Zhurakousky + * @author Jon Schneider */ public class KafkaBinderMetrics implements MeterBinder, ApplicationListener { diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaBinderActuatorTests.java b/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaBinderActuatorTests.java index 4b4362cb3..7a30df22b 100644 --- a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaBinderActuatorTests.java +++ b/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaBinderActuatorTests.java @@ -17,7 +17,6 @@ package org.springframework.cloud.stream.binder.kafka.integration; import io.micrometer.core.instrument.MeterRegistry; -import io.micrometer.core.instrument.search.Search; import org.junit.AfterClass; import org.junit.BeforeClass; @@ -40,6 +39,7 @@ import static org.assertj.core.api.Assertions.assertThat; /** * @author Artem Bilan * @author Oleg Zhurakousky + * @author Jon Schneider * * @since 2.0 */