From c1f4cf9dc63a3601b63e64d34ab8bd914e701630 Mon Sep 17 00:00:00 2001 From: Guillaume Lemont Date: Wed, 24 Apr 2019 12:09:37 +0200 Subject: [PATCH] Fix message listener container bean naming With multiplex topics, topics can be an array. Sine message listener container bean name is created by calling a toString() on the topics, when it is an array it creates an unusual bean name. Fixing the issue by creating the bean name by using destination string directly. --- .../cloud/stream/binder/kafka/KafkaMessageChannelBinder.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java b/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java index add27a2c1..288907aab 100644 --- a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java +++ b/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java @@ -535,7 +535,7 @@ public class KafkaMessageChannelBinder extends messageListenerContainer .setApplicationEventPublisher(getApplicationContext()); } - messageListenerContainer.setBeanName(topics + ".container"); + messageListenerContainer.setBeanName(destination + ".container"); // end of these won't be needed... if (!extendedConsumerProperties.getExtension().isAutoCommitOffset()) { messageListenerContainer.getContainerProperties()