EventStoreDB V20 持久订阅处理器不触发如何正确配置客户端

• gRPC连接配置存在两处错误：

1. 端口指向错误：EventStoreDB的gRPC接口默认运行在1113端口，2113为HTTP仪表板端口，当前配置将gRPC连接指向2113端口，无法建立正常的订阅通道
2. 配置写法无效：URL后缀拼接的?Tls=false&TlsVerifyCert=false不是客户端支持的配置格式，TLS开关需要通过EventStoreClientConnectivitySettings的显式属性配置，靠URL传参会导致客户端按默认逻辑尝试TLS握手，连接直接失败

• $all流订阅配置缺项：V20及以上版本要求，对系统流$all创建持久订阅时必须显式配置消费过滤器，否则即使订阅在仪表板可见，也不会实际拉取事件
• 冗余配置干扰：自定义CreateHttpMessageHandler证书校验逻辑在--insecure明文模式下完全多余，会破坏gRPC通道初始化流程
• 消费起点预期偏差：设置startFrom: StreamPosition.End时，仅会消费订阅创建完成后产生的新事件，创建前追加的历史事件不会被拉取

1. 修正客户端连接配置
   • 连接地址改为gRPC专用端口http://127.0.0.1:1113
   • 移除URL后无意义的TLS相关query参数，http协议头的URI会被客户端自动识别为明文无TLS连接
   • 删除多余的CreateHttpMessageHandler配置，insecure模式下无需自定义证书校验逻辑
2. 为$all持久订阅补充必填的过滤器参数
3. 调整测试流程：先完成订阅建立，再追加测试事件，匹配当前消费起点的配置逻辑

// 初始化持久订阅客户端，直接连接明文gRPC端口
var client = new EventStorePersistentSubscriptionsClient(
    new EventStoreClientSettings
    {
        ConnectivitySettings = new EventStoreClientConnectivitySettings
        {
            Address = new Uri("http://127.0.0.1:1113")
        }
    });

// 带必填过滤器的$all流持久订阅创建
var subSettings = new PersistentSubscriptionSettings(
    startFrom: StreamPosition.End,
    filterOptions: new SubscriptionFilterOptions(
        new StreamFilter(prefixes: new[] { "" })));

await client.CreateAsync(
    streamName: "all",
    groupName: "TestGroup",
    settings: subSettings);

// 建立消费订阅
await client.SubscribeAsync(
    streamName: "all",
    groupName: "TestGroup",
    eventAppearedHandler: (sub, evt, retryCount, ct) =>
    {
        Console.WriteLine("Received: " + Encoding.UTF8.GetString(evt.Event.Data.Span));
        return Task.CompletedTask;
    });

Console.ReadLine();

• 确认Docker容器的1113端口映射正常，无本地进程占用、防火墙拦截
• 先删除仪表板中原有的无效TestGroup订阅，再重新创建带正确配置的订阅，避免配置残留导致的消费异常
• 若需要消费历史事件，可将startFrom改为StreamPosition.Start，重新创建订阅组后测试
• 测试时需在订阅通道建立完成后再追加事件，匹配当前StreamPosition.End的消费起点配置，避免因事件产生时间早于订阅创建时间而收不到回调

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