在EventStore中重新连接到持久连接后，不要重复确认的事件

using System;
using System.Collections.Generic;
using EventStore.ClientAPI;

public class EventStoreClient
{
    private readonly IEventStoreConnection _connection;
    private readonly HashSet<string> _confirmedEventIds = new HashSet<string>();

    public EventStoreClient(string connectionString)
    {
        _connection = EventStoreConnection.Create(connectionString);
        _connection.Connected += OnConnected;
        _connection.Disconnected += OnDisconnected;
        _connection.ConnectAsync().Wait();
    }

    private void OnConnected(object sender, ClientConnectionEventArgs e)
    {
        var subscription = _connection.SubscribeToAllAsync(
            fromEvent: StreamPosition.Start,
            resolveLinkTos: true,
            maxSearchWindow: int.MaxValue,
            credentials: null,
            liveBufferSize: 500,
            readBatchSize: 500,
            checkpointAfterMs: 1000,
            checkpointMaxCount: 1000,
            checkpointToken: null,
            connectionClosed: (sender2, e2) => { },
            messagePump: null);

        subscription.Completed += (sender2, e2) =>
        {
            foreach (var resolvedEvent in subscription.Events)
            {
                if (!_confirmedEventIds.Contains(resolvedEvent.Event.Id))
                {
                    ProcessEvent(resolvedEvent.Event);
                    _confirmedEventIds.Add(resolvedEvent.Event.Id);
                }
            }
        };
    }

    private void OnDisconnected(object sender, ClientConnectionEventArgs e)
    {
        // Handle disconnection
    }

    private void ProcessEvent(EventData eventData)
    {
        // Process the event
        Console.WriteLine($"Processing event: {eventData.EventId}");
    }
}