java - Spring集成Kafka MessaheChannel Thread？

Question

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

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

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

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

Answer 1

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