代码之家 › 专栏 › 技术社区 › italktothewind

spring cloud stream:spring.cloud.stream.default.consumer.concurrency属性的确切含义

spring-cloud-stream

italktothewind · 技术社区 · 5 年前

我想知道使用spring.cloud.stream.default.consumer.concurrency属性时“并发”的确切含义。

文件编制( https://docs.spring.io/spring-cloud-stream/docs/Chelsea.RELEASE/reference/html/_configuration_options.html )表示“入站使用者的并发性”,这可以用几种方式解释。

在幕后创建了什么类型的线程执行器?

谢谢!

1 回复 | 直到 5 年前

sobychacko 5 年前

并发性的语义依赖于实际的绑定器实现。例如,对于kafka绑定器,当设置并发时,该值将传递给底层 MessageListenerContainer . 假设您的使用者应用程序正在使用具有3个分区的主题,并且您设置了 concurrency 到3。这将通过容器创建3个线程,其中每个线程处理主题的单个分区(事实上,对于Kafka活页夹,将在后台创建3个侦听器容器)。如果主题上的分区多于并发线程,那么这些分区将分布在各个线程上。同样的语义也适用于兔子绑定器,尽管它的实际实现在内部可能略有不同。

推荐文章

Roman Lebedev · Spring云流:如果当前连接引发异常,则重新发布到其他amqp连接[关闭]

6 年前

Stav Alfi · Spring集成运动-未找到正确的实现

6 年前

jesantana · 通过在每次应用程序重新启动时创建新的使用者组来重置主题偏移量

6 年前

Mahesh G · Spring云流-并发

6 年前

Alex Kamornikov · 春季云流确定主题卡夫卡消息来源

6 年前

yokv · 卡夫卡制作人始终重试连接

6 年前

samba · 需要Spring集成示例代码aws S3作为入站和apache kafka作为出站的示例[已关闭]

7 年前

sadineni · Spring云数据流商业支持

7 年前

Bully · Rabbit spring云流将主题绑定到单个队列

7 年前

user6448130 · Spring云流媒体-生产者和消费者的独立连接

7 年前