为何Event Hub触发的Azure Function创建检查点时未填充Offset字段

云原生阿岚

2026-9-25

Python Azure Function Event Hub 触发器重启重复消费问题解决方案

你不需要自行实现Offset存储逻辑，Azure Functions Event Hub 绑定默认会处理检查点提交，当前检查点Offset为null是触发检查点提交的条件未满足导致的，按以下步骤排查即可：

确认函数批次执行正常完成
Event Hub 绑定默认仅在整批事件全部处理完成、无未捕获异常抛出时，才会自动提交对应批次的检查点。如果本地调试时在批次处理完成前强行终止进程、或者函数执行报错，都会导致检查点提交失败，Offset一直保持null。
调整host.json的触发器配置适配本地调试
在项目根目录的host.json中添加/更新Event Hub扩展配置，降低检查点提交门槛，方便本地调试验证：
```
{
  "version": "2.0",
  "extensions": {
    "eventHubs": {
      "batchCheckpointFrequency": 1,
      "maxBatchSize": 5,
      "prefetchCount": 10
    }
  }
}
```
其中batchCheckpointFrequency设为1代表每处理完成1批事件就提交一次检查点，避免本地运行时间短没达到默认的提交阈值。
本地停止进程前等待批次处理完成
本地调试时触发函数执行后，等待日志输出当前批次所有事件处理完成的提示后再停止函数进程，确保检查点能正常写入Blob存储。
确认消费组为专属消费组
不要和其他应用共用$Default默认消费组，每个消费逻辑使用独立的消费组，避免不同应用的检查点提交互相冲突。