如何更改[kafka-consumer-1]此線程名稱？

Question

我將併發性設置爲10，我可以看到10個不同的線程ID，但線程名稱都是一樣的。如何設置偵聽器名稱？我試過container.setBeanName但沒有運氣。請幫忙。順便說一下，我使用1.1.2版本

Answer 1

線程名稱是唯一的;只是引導的日誌配置默認會截斷這個名稱;我們將fix the default thread naming，但在此期間，您可以更改日誌記錄配置或使用命名的執行程序。使用在容器的ContainerPropertiessetConsumerTaskExecutor(execC())和setListenerTaskExecutor(execL()) ......

@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; 
}