Spring 集成 Kafka MessaheChannel 线程？

Question

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

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

它是与应用程序一起创建的单个专用线程，还是有一个由 CloudStream 自动创建和配置的线程池，或者其他？

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

Answer 1

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