protected override async Task<PartitionedFilterResponse> Filter(object @event, EventContext context, CancellationToken cancellation)
    {
        var result = await _filterEventCallback(@event, context).ConfigureAwait(false);
        return new PartitionedFilterResponse { IsIncluded = result.ShouldInclude, PartitionId = result.PartitionId.Value };
    }