在我的代码中,我有一个 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