0

当使用 SpringIntegration 在同一个 SpringBoot 应用程序中运行多个 IntegrationFlow 实例时,我想为特定的 IntegrationFlow 进程分配更多资源(线程优先级)。

我有两个 IntegrationFlow 实例链接到两种不同的源类型。一个链接到 SFTP 源,另一个链接到数据源。当 SFTP 消息经过几个步骤(解压缩包含 XML 文件的文件、检查 XML 文件与 XSD 模式的有效性、拆分 XML 文件并持久化与 XML 文件的一部分相对应的数据)后,第二个工作流以并行方式运行,消耗每个持久化的来自数据源的数据,以便将它们推送到 Kafka 主题中。所以我想在第一个 IntegrationFlow 上分配更多资源。对于每个 InegrationFlow,最大获取大小设置为 1。

4

0 回答 0