Azure EventHubs 非epoch接收器不允许异常该如何排查解决？

• 核心冲突是Epoch模式接收器和非Epoch模式接收器混用在同一个消费者组：Azure Function的Event Hub触发器默认采用Epoch模式连接消费者组，默认Epoch值为0，该模式会获得分区的独占访问权；而你自定义开发的EventHubConsumerClient默认采用非Epoch模式，只要存在活跃的Epoch接收器，非Epoch接收器就会被拒绝连接，抛出你遇到的异常。
• 异常持续1小时的原因：Epoch接收器的分区独占租约默认过期时间为1小时，即使发送方（比如Azure Function实例异常退出、开发者本地调试直接杀进程）没有主动释放租约，服务端也要等1小时租约过期才会允许其他模式的接收器接入。
• 你当前所有服务、开发者调试、Azure Function都共用DefaultConsumerGroupName同一个消费者组，且当前只有1个分区，所有消费者都争抢同一个分区的访问权，大幅提升了冲突概率。
• 补充说明：你之前了解的单分区最多5个消费者的限制，只针对同模式下的非Epoch接收器，Epoch模式本身是独占访问的，和这个限制完全无关，所以报错信息不一样。

1. 核心整改：不同消费者使用独立的消费者组
   Event Hub的消费者组是为不同业务逻辑的消费者准备的隔离单元，你现在有3个业务服务、1个Azure Function、DEV调试场景，至少需要创建5个独立的消费者组，每个场景各自用自己的消费者组，从根源避免不同消费者的访问冲突。

   注意：消费者组可以在Azure门户的Event Hub实例下直接创建，无额外成本，默认配额支持20个消费者组，足够你当前场景使用。

2. 统一消费者的Epoch配置（可选，适配特殊场景）
   如果确实需要多个消费者共用同一个消费者组（不推荐），要么全部关闭Epoch模式，要么所有消费者都配置递增的Epoch值，避免混合模式：

   • 自定义消费者开启Epoch的代码：创建EventHubConsumerClient时传入EventHubConsumerClientOptions，设置OwnerLevel属性（即Epoch值，数值越高优先级越高，高Epoch的消费者会踢掉低Epoch的）：

     var consumerOptions = new EventHubConsumerClientOptions
     {
         OwnerLevel = 1 // 高于Azure Function默认的0的话就会踢掉Azure Function的接收器
     };
     await using var consumer = new EventHubConsumerClient(consumerGroup, connString, eventHubName, consumerOptions);
     

   • 如果要关闭Azure Function的Epoch模式，可以在Function的触发器配置里加ownerLevel = -1参数。

3. 优化代码的消费者实例生命周期
   你当前代码里每次循环异常重试都会重新创建EventHubConsumerClient实例，频繁创建销毁实例会增加连接冲突概率，建议：

   • 每个分区只保留一个长活的EventHubConsumerClient实例，不要每次异常就销毁重建，只有遇到不可恢复的连接错误时再重建。
   • 确保实例销毁时的DisposeAsync能正常执行，不要暴力终止进程导致租约没有主动释放。

4. DEV环境单独配置隔离
   开发者本地调试时不要连接DEV环境共用的Event Hub，要么用本地模拟器，要么给每个开发者分配独立的消费者组，避免本地调试启动/停止进程频繁触发租约锁定。

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