我有一个名为A的mongodb集合,在这个集合中有一个名为field1的日期和时间字段。在我的场景中,我必须根据field1收集过期日期和时间的记录。
我想写spring scheduler作业,它每分钟运行一次,从mongodb中获取过期的日期和时间记录,但是当我开始写时,我无法使springscheduler具有可伸缩性。
问题是,在spring scheduler中,如何停止对Kafka主题的重复消息,或者如何在没有任何重复消息的情况下实现可伸缩的调度器?
有没有基于事件的框架来支持我的场景?意味着当记录过期时,它应该立即通知java系统,即类似于spring中的TailableCursorlisteners侦听cappedcollection。
