0

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

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

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

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

4

1 回答 1

1

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

于 2020-07-23T13:34:50.847 回答