我想知道使用 spring.cloud.stream.default.consumer.concurrency 属性时“并发”的确切含义。
文档（https://docs.spring.io/spring-cloud-stream/docs/Chelsea.RELEASE/reference/html/_configuration_options.html）表示“入站消费者的并发性”，这可以通过多种方式解释。
幕后创建了什么样的线程执行器？
Thanks!
并发的语义取决于实际的绑定器实现。例如，在 Kafka 绑定器的情况下，当您设置并发时，该值将传递给底层MessageListenerContainer。假设您的消费者应用程序正在从具有 3 个分区的主题进行消费，并且您设置了concurrency到 3。这将通过容器创建 3 个线程，其中每个线程都处理主题中的单个分区（事实上，在 Kafka 绑定器的情况下，将在幕后创建 3 个侦听器容器）。如果主题上的分区多于并发线程数，则分区将分布在各个线程上。相同的语义也适用于 Rabbit 绑定器，尽管它的实际实现在内部可能略有不同。
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
