Spring Cloud Stream 1.0.0-RELEASEとスレッド

Question

以前私がRC2を使用していたとき、各カフカ消費者が独自のスレッド（この例ではプール-6スレッド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にアップグレードした後に、同じスレッド（カフカ-binder-）は関係なく、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です。