diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainer.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainer.java
index e38d6a7c..ae2f94e6 100644
--- a/spring-kafka/src/main/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainer.java
+++ b/spring-kafka/src/main/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainer.java
@@ -154,9 +154,8 @@ public class ConcurrentMessageListenerContainer<K, V> extends AbstractMessageLis
 					container = new KafkaMessageListenerContainer<>(this, this.consumerFactory,
 							containerProperties, partitionSubset(containerProperties, i));
 				}
-				if (getBeanName() != null) {
-					container.setBeanName(getBeanName() + "-" + i);
-				}
+				String beanName = getBeanName();
+				container.setBeanName((beanName != null ? beanName : "consumer") + "-" + i);
 				if (getApplicationEventPublisher() != null) {
 					container.setApplicationEventPublisher(getApplicationEventPublisher());
 				}