Spring集成Kafka MessaheChannel Thread？答案

【问题标题】：Spring integration Kafka MessaheChannel Thread?Spring集成Kafka MessaheChannel Thread？
【发布时间】：2020-07-23 04:22:29
【问题描述】：

我有一个 Spring Integration 流 bean（通过 Java DSL 配置），它处理来自与 Spring CloudStream 绑定的 kafka 队列消息通道的消息。

kafka 消息的来源是一个外部应用程序，所以我真正想了解的是，哪些线程/线程将实际处理该消息。

它是由应用程序创建的单个专用线程，还是由 CloudStream 自动创建和配置的线程池，或其他什么？

我能以某种方式管理它吗？

【问题讨论】：

【解决方案1】：

kafka 消息通道绑定器默认使用一个线程；如果您增加绑定 consumer.concurrency 属性，您将获得该数量的线程 - 您至少需要与 concurrency 设置一样多的分区，因为一个分区只能由一个消费者使用。

【讨论】：