EventStoreDB(Kurrent)无法删除事件，如何截断流保留前序事件？

核心结论 #

EventStoreDB（尤其是KurrentDB存储模式下）不支持删除流中间的事件，但截断流到目标事件的前一个位置可以实现你删除末尾事件、保留前面事件的需求——截断操作会保留指定位置及之前的所有事件，移除之后的事件。

你的代码问题分析 #

你当前使用StreamRevision.FromStreamPosition(e.Event.EventNumber)作为截断位置，这会保留到该事件本身（包括它），所以最后一个事件不会被移除。比如你的例子中三个事件编号为0（product_created）、1（product_renamed）、2（product_price_updated），如果要删除最后一个，需要截断到编号1的位置，这样只会保留前两个事件。

正确实现代码 #

场景1：已知要保留的最后一个事件编号

直接指定截断到目标编号：

var streamId = e.Event.EventStreamId;
// 保留前两个事件，截断到编号1的位置（EventStore事件编号从0开始）
var truncateRevision = StreamRevision.FromStreamPosition(1);
// 执行硬删除，彻底移除截断位置之后的事件
var result = await eventStoreClient.DeleteAsync(streamId, truncateRevision, DeleteState.HardDelete);

场景2：动态获取要保留的最后一个事件编号

如果不确定流中的事件数量，可以先读取流事件列表，再计算截断位置：

var streamId = e.Event.EventStreamId;
// 读取流中所有事件（按需调整maxCount参数）
var streamReader = eventStoreClient.ReadStreamAsync(
    Direction.Forwards, 
    streamId, 
    StreamPosition.Start, 
    maxCount: 100);

List<ResolvedEvent> events = new();
await foreach (var ev in streamReader)
{
    events.Add(ev);
}

// 保留前2个事件，取第2个事件的编号（索引1）
var lastKeepEventNumber = events[1].Event.EventNumber;
var truncateRevision = StreamRevision.FromStreamPosition(lastKeepEventNumber);

await eventStoreClient.DeleteAsync(streamId, truncateRevision, DeleteState.HardDelete);

关键参数说明 #

• DeleteState.HardDelete：彻底移除截断位置之后的事件，无法再通过任何方式读取。
• DeleteState.SoftDelete：仅标记事件为删除，事件仍存储在数据库中，但无法通过正常流读取接口访问。根据你的需求，推荐使用HardDelete。

特殊场景说明 #

如果你的需求是删除流中间的某一个事件（比如删除第二个事件，保留第一个和第三个），KurrentDB模式下无法直接实现，只能通过创建新流、重新写入需要保留的事件，然后删除原流的方式间接实现。

内容的提问来源于stack exchange，提问作者Maxim Kitsenko