更改用于运行@StreamListener 方法的线程名称

Question

我想更改用于@StreamListener 方法的线程名称，因为当前名称在日志中太长。我查看了文档，但无法获得任何信息。有什么办法吗？

例如。 KafkaConsumerDestination{consumerDestinationName='TOPIC_NAME', partitions=1, dlqName='null'}.container-0-C-1

Answer 1

添加容器定制器@Bean...

@Bean
public ListenerContainerCustomizer<AbstractMessageListenerContainer<?, ?>> customizer() {
    return (container, destinationName, group) -> {
        container.setBeanName(group + "." + destinationName);
    };
}

bean 名称用作线程名称的前缀。