Commit 23c55498 authored by Stephane Nicoll's avatar Stephane Nicoll

Polish

parent a03426af
......@@ -59,11 +59,11 @@ public class KafkaMetricsAutoConfiguration {
}
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));
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment