有关Spring Integration项目的问题，请使用此标记。它不适用于将其他Spring项目与其他技术集成的一般问题。
Spring Batch 中的远程分区 - 在大量记录的作业完成之前，少量记录的作业无法完成
我正在尝试使用远程分区[主从方法]的Spring Batch。 我有一个主步骤，通过 KAFKA 将记录发送到工作节点。 一切都工作正常，直到并行作业执行......
拥有一个由多个集成流程组成的 Spring Integration 应用程序，并且该应用程序总共部署为 Kubernetes 中的容器。容器根据负载自动缩放......
Spring Integration & MQ 中设计超时处理
我正在开发一个正在重组为一致异步的应用程序。它过去是，现在仍然是基于 Spring Integrations。作为支付网关，我可以参考ISO 20022标准...
Spring 集成 HttpRequestExecutingMessageHandler ContentType 问题
我面临 Spring Integration 的问题。我正在尝试通过 HttpRequestExecutingMessageHandler 执行休息调用。我的休息端点仅接受内容类型“application/json”。 该项目...
与 Spring Integration Flows 一起使用时如何处理关闭 ExecutorService？
我正在使用执行程序服务来确保传入的 jms 消息在将它们写入数据库后得到确认 - （使用 XA 数据源和分布式事务不是我们的选择...
Spring AMQP 集成从 2.2.3.RELEASE 到 5.5.20
我正在从 Spring AMQP inetgration 从 2.2.3.RELEASE 迁移到 5.5.20.and 这是我的 mvn 依赖树矩阵。 [信息] | +- org.springframework.integration:spring-integration-stream:jar:5.5.20:
使用Spring EL或属性占位符动态设置@Gateway和@ServiceActivator的输入/输出通道
注解@MessagingGateway允许使用属性占位符${}设置defaultRequestChannel： @MessagingGateway(defaultRequestChannel = "${gateway.request.channel}") 公开
我正在使用来自 Kafka 的消息，并使用远程文件服务器上的 SFTP 出站适配器将这些消息写入文件。该应用程序将在云环境中运行多实例。 我正在使用领导者
将 spring 从 4.x 迁移到 5.x 和 jdk 17
我的应用程序中有 spring 依赖项和 spring 集成依赖项。 我已将 spring 从 4.1.1.RELEASE 迁移到 5.3.39，并将 spring 集成从 2.2.3.RELEASE 迁移到 5.5.20。 我有
我希望通过拆分/聚合来实现集成流程。我想捕获处理程序抛出的异常，并迭代一一拆分的所有元素，即使某些元素失败也是如此。当...
spring集成DSL流到另一个流不执行enrichedHeaders
我正在使用 Spring Integration 6.3.3。我的主要 IntegrationFlow 从 PubSubInboundAdapter 消耗，定义如下： 公共 IntegrationFlow flowA( 过滤器1 过滤器1, ...
使用 Spring 集成，我通过 QueueChannel 从使用 Spring 的 @ScheduledService 注释的方法发送消息到使用 @ServiceActivator 注释的方法。我期待@
在 spring-cloud-stream-binder-kafka 中配置（spring 集成的）logginghandler
我对这个问题有一个后续问题 有没有办法在 Spring Cloud Stream 中自定义 Spring Integration 模块的 LoggingHandler ？即设置 shouldLogFullMessage 为 false 或
我正在尝试创建 IntegrationFlowAdapter 类的实现，它允许我获取推送通知，为每个设备令牌复制它，拆分推送通知列表并拥有它
spring-integration-sftp 流程在第一个计划后随机运行
spring-integrations-sftp 配置如下 @豆 公共 SessionFactory sessionFactory() { 最终 DefaultSftpSessionFactory 工厂 = 新
S3 Spring Integration (AWS) 无法正确创建本地文件夹
这是我的 Spring Integration 配置： @配置 @EnableIntegration 公共类 S3IntegrationConfig { @豆 公共 S3Client s3Client() { 返回S3Client.create(); } @...
如何将 bean 注入 @InboundChannelAdapter？
考虑到使用@InboundChannelAdapter注解的方法由于某种原因无法接受任何参数，我该如何注入bean呢？该注释的通道属性已经引用了...
我当前的工作流程有 2 个集成流程 - 第一个集成流程 - 从 SFTP 轮询文件 -> 消息处理程序 -> 将消息发送到 JdbcChannelMessageStore 并将这些消息保存在 Jdbc 中...
如果 DynamoDB 中已经存在检查点，streamInitialSequence 的效果是什么？
我想使用 KinesisMessageDrivenChannelAdapter 从 Kinesis 流中读取记录。第一次启动消费者应用程序时，我希望它接收所有记录......