spring-batch-stream相关内容

重载弹簧批量多道工序,每道工序下有多个螺纹

我有一个方案,在该方案中,我需要同时运行大约50-60个不同的进程并执行任务。 每个进程都必须通过传递一个值并获取要在后续任务中运行的数据,从而使用SQL查询从DB获取数据。 从TABLE_1中选择COL_1、COL_2、COL_3,其中COL_1=:PROCESS_1; @Bean public Job partitioningJob() throws Exception { ..

使用 Spring Cloud Stream kafka 动态更改实例索引

类似于:更改 spring-cloud-stream 实例索引/运行时计数 我在微服务器架构中对批处理的启动做了一个 poc,我正在将 Spring 批处理与 Spring Cloud Stream Kafka 一起使用.我正在寻找一种方法来动态创建消费者(处理器)应用程序的多个实例.我看到可以用 定义多个实例 spring.cloud.stream.instanceCount=nspr ..

使用 Spring Cloud Stream kafka 动态更改实例索引

类似于:更改 spring-cloud-stream 实例索引/运行时计数 我在微服务器架构中对批处理的启动做了一个 poc,我正在将 Spring 批处理与 Spring Cloud Stream Kafka 一起使用.我正在寻找一种方法来动态创建消费者(处理器)应用程序的多个实例.我看到可以用 定义多个实例 spring.cloud.stream.instanceCount=nspr ..

在 xml spring 批处理应用程序中复制标题标记

我在 spring-boot 应用程序中使用 spring-batch.Spring Boot 版本为 2.3.3.RELEASE. 我想达到的目标 我必须读取一个xml文件,其中包含数以千计的Transactions和header tag(文件信息).在事务上做一些业务逻辑,然后用事务中更新的值写回文件.我使用 StaxEventItemReader 读取文件,使用 StaxEven ..