Polish

chenhxbj · May 13, 2020 · 23c5549 · 23c5549
1 parent a03426a
commit 23c5549
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...org/springframework/boot/actuate/autoconfigure/metrics/KafkaMetricsAutoConfiguration.java b/...org/springframework/boot/actuate/autoconfigure/metrics/KafkaMetricsAutoConfiguration.java
@@ -59,11 +59,11 @@ public DefaultKafkaConsumerFactoryCustomizer kafkaConsumerMetrics(MeterRegistry
 	}
 
 	private <K, V> void addListener(DefaultKafkaConsumerFactory<K, V> factory, MeterRegistry meterRegistry) {
-		factory.addListener(new MicrometerConsumerListener<K, V>(meterRegistry));
+		factory.addListener(new MicrometerConsumerListener<>(meterRegistry));
 	}
 
 	private <K, V> void addListener(DefaultKafkaProducerFactory<K, V> factory, MeterRegistry meterRegistry) {
-		factory.addListener(new MicrometerProducerListener<K, V>(meterRegistry));
+		factory.addListener(new MicrometerProducerListener<>(meterRegistry));
 	}
 
 }