这个代码我倒是没怎么看过，不过 LZ 寻找的东西貌似和我很相似，在网上找了很多例子发现都不太符合自己的需求。所以最后我是 axon 实现了 Event Sourcing + CQRS，然后拓展了下事件的存储来保证事件发布到消息中间件的一致性问题（通过 Spring Cloud Stream ），Consumer 的消费顺序问题，我没有做深入的处理，只是所有的 Domain Event 都会带上 axon 中的 seq，在 Consume 的时候碰到 seq 不对的，在重试几次之后就直接丢到 DLQ 中走失败流程了。

楼主只是比较年轻罢了，多经历经历就好了，可能人你都还不熟，熟了之后调侃什么的简直就随意