我有一个 Spring Integration 流 bean(通过 Java DSL 配置),它处理来自与 Spring CloudStream 绑定的 kafka 队列消息通道的消息。
kafka 消息的来源是一个外部应用程序,所以我真正想了解的是,哪些线程/线程将实际处理该消息。
它是使用应用程序创建的单个专用线程,还是 CloudStream 自动创建和配置的线程池,或者其他什么?
我能以某种方式管理它吗?
我有一个 Spring Integration 流 bean(通过 Java DSL 配置),它处理来自与 Spring CloudStream 绑定的 kafka 队列消息通道的消息。
kafka 消息的来源是一个外部应用程序,所以我真正想了解的是,哪些线程/线程将实际处理该消息。
它是使用应用程序创建的单个专用线程,还是 CloudStream 自动创建和配置的线程池,或者其他什么?
我能以某种方式管理它吗?