File tree Expand file tree Collapse file tree 4 files changed +8
-7
lines changed
spring-kafka/src/main/java/org/springframework/kafka Expand file tree Collapse file tree 4 files changed +8
-7
lines changed Original file line number Diff line number Diff line change 6666 junitJupiterVersion = ' 5.8.2'
6767 kafkaVersion = ' 3.1.0'
6868 log4jVersion = ' 2.17.1'
69- micrometerVersion = ' 2.0.0-M1 '
69+ micrometerVersion = ' 2.0.0-SNAPSHOT '
7070 mockitoVersion = ' 4.0.0'
7171 reactorVersion = ' 2020.0.16'
7272 scalaVersion = ' 2.13'
@@ -338,6 +338,7 @@ project ('spring-kafka') {
338338 optionalApi ' io.projectreactor:reactor-core'
339339 optionalApi ' io.projectreactor.kafka:reactor-kafka'
340340 optionalApi " io.micrometer:micrometer-core:$micrometerVersion "
341+ optionalApi " io.micrometer:micrometer-binders:$micrometerVersion "
341342
342343 testImplementation project (' :spring-kafka-test' )
343344 testImplementation ' io.projectreactor:reactor-test'
Original file line number Diff line number Diff line change 11/*
2- * Copyright 2020 the original author or authors.
2+ * Copyright 2020-2022 the original author or authors.
33 *
44 * Licensed under the Apache License, Version 2.0 (the "License");
55 * you may not use this file except in compliance with the License.
2424
2525import org .apache .kafka .clients .consumer .Consumer ;
2626
27+ import io .micrometer .binder .kafka .KafkaClientMetrics ;
2728import io .micrometer .core .instrument .ImmutableTag ;
2829import io .micrometer .core .instrument .MeterRegistry ;
2930import io .micrometer .core .instrument .Tag ;
30- import io .micrometer .core .instrument .binder .kafka .KafkaClientMetrics ;
3131
3232/**
3333 * A consumer factory listener that manages {@link KafkaClientMetrics}.
Original file line number Diff line number Diff line change 11/*
2- * Copyright 2020 the original author or authors.
2+ * Copyright 2020-2022 the original author or authors.
33 *
44 * Licensed under the Apache License, Version 2.0 (the "License");
55 * you may not use this file except in compliance with the License.
2424
2525import org .apache .kafka .clients .producer .Producer ;
2626
27+ import io .micrometer .binder .kafka .KafkaClientMetrics ;
2728import io .micrometer .core .instrument .ImmutableTag ;
2829import io .micrometer .core .instrument .MeterRegistry ;
2930import io .micrometer .core .instrument .Tag ;
30- import io .micrometer .core .instrument .binder .kafka .KafkaClientMetrics ;
3131
3232/**
3333 * A producer factory listener that manages {@link KafkaClientMetrics}.
Original file line number Diff line number Diff line change 11/*
2- * Copyright 2020 the original author or authors.
2+ * Copyright 2020-2022 the original author or authors.
33 *
44 * Licensed under the Apache License, Version 2.0 (the "License");
55 * you may not use this file except in compliance with the License.
2626
2727import org .springframework .kafka .config .StreamsBuilderFactoryBean ;
2828
29+ import io .micrometer .binder .kafka .KafkaStreamsMetrics ;
2930import io .micrometer .core .instrument .ImmutableTag ;
3031import io .micrometer .core .instrument .MeterRegistry ;
3132import io .micrometer .core .instrument .Tag ;
32- import io .micrometer .core .instrument .binder .kafka .KafkaStreamsMetrics ;
3333
3434/**
3535 * Creates a {@link KafkaStreamsMetrics} for the {@link KafkaStreams}.
You can’t perform that action at this time.
0 commit comments