我正在研究cqrs，并希望使用kafka实现saga模式来处理分布式事务。
saga将从其他聚合订阅域事件以发送命令。我的问题是，域事件也将由聚合事件处理程序处理。
如果聚合事件处理程序成功地处理了事件，那么将提交偏移量，以便代理中的作业消失。
假设聚合事件处理程序成功地处理了该事件，但是由于某些意外问题而没有触发saga。既然工作没了，如果他们都生活在同一个消费群体中，这个事件就永远不会被传奇故事所关注。。。
那么，将一个消费群体作为一个整体，并为这个传奇创造另一个消费群体，这有意义吗？