spring-kafka - 如何更改 [kafka-consumer-1] 这个线程名称？

Question

我将并发设置为 10，我可以看到 10 个不同的线程 ID，但线程名称都是一样的。如何设置监听器名称？我试过 container.setBeanName 但没有运气。请帮忙。顺便说一句，我使用的是 1.1.2 版本

Answer 1

线程名称是唯一的；只是引导的日志配置默认截断了名称；我们将修复默认线程命名，但与此同时，您可以更改日志配置或使用命名执行器。使用setConsumerTaskExecutor(execC())和setListenerTaskExecutor(execL())在容器的ContainerProperties...

@Bean
public AsyncListenableTaskExecutor execC() {
    ThreadPoolTaskExecutor tpte = new ThreadPoolTaskExecutor();
    tpte.setCorePoolSize(15);
    return tpte;
}

@Bean
public AsyncListenableTaskExecutor execL() {
    ThreadPoolTaskExecutor tpte = new ThreadPoolTaskExecutor();
    tpte.setCorePoolSize(15);
    return tpte;
}