0

以前 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 にアップグレードした後、プロパティの設定に関係なく、同じスレッド ( kafka-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}] - {}

これは新しいデフォルトの動作ですか? それぞれ独自のスレッドで実行される MessageChannelBinders のプールを利用するようにアプリケーションを構成するにはどうすればよいですか?

4

1 に答える 1

0

プールが使用されますが、残念ながら、スレッドにはすべて同じ名前が付けられます。

これはバグです。問題を作成しました。

于 2016-05-17T18:42:27.637 に答える