diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java index acbe0d45..62f8dcf7 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java @@ -166,7 +166,7 @@ public class KafkaMessageListenerContainer extends AbstractMessageListener Iterator metricIterator = metrics.keySet().iterator(); if (metricIterator.hasNext()) { String clientId = metricIterator.next().tags().get("client-id"); - return Collections.singletonMap(clientId, metrics); + return Collections.>singletonMap(clientId, metrics); } } return Collections.emptyMap();