Spring的云流：Spring。云流动违约消费者并发属性的确切含义
我想知道使用spring时“并发”的确切含义。云流动违约消费者并发属性。
文档（https://docs.spring.io/spring-cloud-stream/docs/Chelsea.RELEASE/reference/html/_configuration_options.html）表示“入站消费者的并发”，这可以通过多种方式解释。
幕后创建了什么类型的线程执行器？
谢啦！
共有1个答案
并发的语义取决于实际的绑定器实现。例如，在Kafka活页夹的情况下，当您设置并发性时，该值将传递给底层的MessageListenerContainer。假设您的使用者应用程序正在使用一个具有3个分区的主题，并且您将并发性的值设置为3。这将通过容器创建3个线程，其中每个线程都处理来自主题的单个分区（事实上，对于Kafka binder，将在幕后创建3个侦听器容器）。如果主题上的分区多于并发线程，那么分区将分布在各个线程上。同样的语义也适用于Rabbit绑定器，尽管它的实际实现在内部可能略有不同。
-
更新： 根据答案，下面的配置在绑定器级别工作。
-
使用Spring Cloud Stream版本Chelsea. SR2，RabbitMQ作为消息代理。要拥有多个消费者，我们使用属性并发（入站消费者的并发）。 如果我们将并发设置为50。它从1开始，慢慢地增加消费者计数。有没有任何可能的解决方案可以使用更高的数字而不是一个来启动初始消费者计数，以提高消费者性能。
-
我目前正在使用带有的Kafka绑定器的Spring Cloud Stream为我的Spring Boot微服务执行消息记录。 我有： 生产者将消息发布到订阅频道 在消息从生产者发布到流并被消费者收听的整个过程中，可以观察到preSend方法被触发了两次： 一次在生产者端-消息发布到流时 然而，出于日志记录的目的，我只需要在消费者端截获并记录消息。 是否有任何方法可以仅在一侧（例如消费者侧）截获SC
-
我想使用bean向Kafka发送带有在运行时解析的主题名称的消息。我的问题是，本主题的中的默认值为1。 当Kafka中已经存在此主题时，以及当客户端创建此主题时（分区计数等于配置值），此值并不反映真正的分区数。 如何使此属性反映分区的真实数目？
-
我有一个服务，它从不同的Spring云流通道（绑定到EventHub/Kafka主题）生成和使用消息。有几种设置类似的服务。 配置如下所示 生产者/发布者代码如下所示 类似地，我还有多个其他发布者发布到不同的活动中心/主题。请注意，每个已发布的消息都有一个租户id标头。这是我的多租户应用程序特定于跟踪租户上下文的内容。还请注意，在发送消息时，我正在获取要发布到的频道。 我的消费者代码如下所示 同样
-
如何使用新的Spring Cloud Stream Kafka功能模型发送消息？ 不推荐的方式是这样的。 但是我如何以函数式风格发送消息呢？ 应用yml公司 我会自动连接MessageChannel，但对于process、process-out-0、output或类似的东西，没有MessageChannel Bean。或者我可以用供应商Bean发送消息吗？谁能给我举个例子吗？谢谢！