Spring/spring-kafka
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

KBGH-356: Fix thread naming with no bean name

Browse Source 
See https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/356

Use token 'consumer' for thread prefix when no bean name.

**cherry-pick to 2.0.x, 1.3.x**
This commit is contained in:
Gary Russell
2018-04-16 11:37:47 -04:00
committed by Artem Bilan
parent f715bbef8b
commit fd694470ad
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
spring-kafka/src/main/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainer.java
View File

@@ -153,9 +153,8 @@ public class ConcurrentMessageListenerContainer<K, V> extends AbstractMessageLis
container = new KafkaMessageListenerContainer<>(this, this.consumerFactory, container = new KafkaMessageListenerContainer<>(this, this.consumerFactory,
containerProperties, partitionSubset(containerProperties, i)); containerProperties, partitionSubset(containerProperties, i));
} }
if (getBeanName() != null) { String beanName = getBeanName();
container.setBeanName(getBeanName() + "-" + i); container.setBeanName((beanName != null ? beanName : "consumer") + "-" + i);
}
if (getApplicationEventPublisher() != null) { if (getApplicationEventPublisher() != null) {
container.setApplicationEventPublisher(getApplicationEventPublisher()); container.setApplicationEventPublisher(getApplicationEventPublisher());
} }