Change Data Capture — jede Änderung als Stream

// A durable ConsumerName makes the server track this consumer's committed
// offset and lag — reopen the feed and it resumes automatically.
var options = new ChangeFeedOptions
{
    ConsumerName = "search-indexer",
    KeyPrefix    = "product:",                       // server-side filter
    Kinds        = new[] { FeedEventKind.Put, FeedEventKind.Delete },
};

var feed = (IZarisChangeFeedClient)client;           // the Zaris client is a feed consumer

await foreach (ChangeEvent e in feed.OpenChangeFeed(options, ct))
{
    if (e.IsDelete)
        await index.RemoveAsync(e.Key);
    else if (e.Value is { } bytes)                   // raw bytes of a plain-value write
        await index.UpsertAsync(e.Key, bytes, e.ExpiresAtUnixMs);
    // No manual commit: the named consumer's offset is tracked server-side.
}