3.4 CQRS、ES与流处理