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 回答