我正在开发一个系统，它可以在某些数据更改时向侦听器发送事件。每个事件都被引用到一个聚合根（假设它是一个customer，事件是customercreatedevent和customerupdatevent）。
由于短时间内产生的事件数量可能很高，而且事件通知系统的构建方式使得每次都会发送一个完整的customerdto，因此我正在尝试找到一种最佳方法，在一个时间窗口中仅为每个客户发送最新的事件，并丢弃以前的事件。
在java中实现这种机制的最佳方法是什么？
谢谢朱利奥