Spring Cloud Stream 1.0.0-RELEASE和Threads

Question

以前，當我使用RC2時，我觀察到每個kafka使用者似乎都在自己的線程中執行（在本例中，pool-6-thread-1）：

2016-05-13 12:13:14 pool-6-thread-1 DEBUG KafkaMessageChannelBinder$ReceivingHandler:115 - org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$ReceivingHandler@2b461688 received message: GenericMessage [payload=byte[400], headers={kafka_offset=17, kafka_messageKey=null, kafka_topic=redeemed, kafka_partitionId=0, kafka_nextOffset=18}] - {} 

但升級到1.0.0RELEASE後，似乎在同一個線程（卡夫卡粘合劑 -）被用於所有的消費，無論設置concurrency屬性：

2016-05-17 14:14:18 kafka-binder- DEBUG KafkaMessageChannelBinder$ReceivingHandler:115 - org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$ReceivingHandler@5044f552 received message: GenericMessage [payload=byte[287], headers={kafka_offset=62, kafka_messageKey=null, kafka_topic=error.redeemed.poc, kafka_partitionId=0, kafka_nextOffset=63}] - {} 

這是新的默認行爲？如何配置我的應用程序以利用每個在自己的線程中執行的MessageChannelBinder池？

Answer 1

使用了一個池，但不幸的是，這些線程都被賦予了相同的名稱。

這是一個錯誤 - 我created an issue for it。