Spring集成-生产者队列容量限制
我们使用带有MessageChannelPartitionHandler的远程分区来发送分区消息到队列(ActiveMQ),以便对工作人员进行挑选和处理。作业有大量的数据需要处理,许多分区消息正在发布到队列,来自replyChannnel的响应聚合器由于消息超时而失败,因为所有消息都不能在给定的时间内处理。我们还试图通过使用队列容量<integration:queue ca
我们已经将大量Spring批处理分区作业从2.2迁移到4.x (分区作业的XML配置)。当我调试分区作业时,我得到这个堆栈跟踪:
2020-05-13 17:03:38,311 ERROR [org.springframework.batch.core.step.AbstractStep]cannot be cast to class java.util.Collection (org.springframework.batc
我正在编写一个远程分区作业,并且能够使用共享数据源(MySql)很好地运行该作业,但是当我想要运行不希望在主服务器和远程从服务器之间共享数据库的作业时,远程从服务器在收到来自主服务器的消息时会失败,并出现以下异常Caused by: org.springframework.batch.core.step.NoSuchStepException: No StepExecution could be locatedStepExecutionRequest: [jobExec
这是I need current easy to follow instructions for configuring spring integration kafka from XML的后续问题Spring-integration-kafka在过去的几次迭代中发展了很多,许多旧的例子不再起作用。特别是,这个从spring-batch世界到spring集成世界的bean将不会实例化,因为KafkaTemplate类