spring-boot - camel-sql 消费者在每个批次问题中轮询新记录

Question

在我的代码中，我有一个 camel-sql 消费者，它在默认的 consumer.delay=500 上运行，每次轮询的 Max msg 为 5。

消费者正在从 Customer 表中获取数据，并在 Customer_status 表上加入（Customer.Cust_id = Customer_status.Cust_id，其中 Customer_status.Cust_id 为 NULL）。

维护 Customer_status 的想法是维护已处理记录的状态并确保下一批没有上一批的记录（根据加入条件）

但是在程序运行期间，一些批次的记录是在较早的批次中提取的。

所以我正在寻找一种方法来帮助我在每批中保持独特性。因为我的方法不是 100% 有效。

将 Camel 与 Springboot DB 一起使用：Oracle

标签： spring-bootapache-camelbatch-processingcamel-sql