Azure.Messaging.EventHubs.Processor 5.12.0版本发布：地理数据复制与偏移量改进

项目简介

Azure.Messaging.EventHubs是微软Azure平台提供的用于处理事件流数据的.NET客户端库，而EventHubs.Processor则是其中负责事件处理的核心组件。它提供了事件处理、检查点管理和分区负载均衡等功能，是构建实时事件处理应用程序的重要工具。

核心更新内容

地理数据复制功能支持

本次5.12.0版本最重要的更新是增加了对Event Hubs地理数据复制(GeoDR)功能的支持。这一功能允许用户将事件数据自动复制到另一个地理区域，提高业务的连续性和灾难恢复能力。

开发者现在可以通过EventHubProducerClient或EventHubConsumerClient查询Event Hub属性，检查IsGeoReplicationEnabled属性来判断是否启用了地理数据复制功能。这一改进使得应用程序能够更好地适应不同配置的Event Hubs环境。

偏移量数据类型的重大变更

为了配合地理数据复制功能的实现，偏移量(offset)相关数据的类型从原来的long变更为string。这一变更主要影响以下几个方面：

1. 新增字符串类型的偏移量成员：

   • 新增了以OffsetString为后缀的成员和方法重载
   • 字符串类型的偏移量能够更好地适应地理数据复制场景

2. 向后兼容性处理：

   • 原有的long类型偏移量成员仍然保留但标记为过时(obsolete)
   • 这些过时成员在未启用GeoDR的命名空间中仍然可用

3. 过时的成员和方法：

   • 属性：EventData.Offset、LastEnqueuedEventProperties.Offset、PartitionProperties.LastEnqueuedOffset
   • 方法：EventPosition.FromOffset、EventHubsModelFactory.EventData等重载

其他重要改进

检查点更新修复

修复了EventProcessorClient.UpdateCheckpointAsync方法中的一个重要问题，现在该方法会正确等待检查点存储的调用完成。之前的版本中，这个等待操作被遗漏，导致OpenTelemetry(OTel)跨度过早关闭，无法正确报告观察到的错误。

重试逻辑增强

改进了基于WebSocket的故障重试逻辑，现在会考虑更多异常情况。特别是当WebSocketException包含内部SocketException时，重试决策会基于内部异常做出，确保在网络条件不佳时能够正确应用重试策略。

性能与兼容性优化

1. AOT和裁剪支持：

   • 添加了必要的注解，使包能够兼容裁剪(trimming)和原生AOT编译
   • 这对于优化应用程序大小和启动性能非常重要

2. 日志增强：

   • 在处理器负载均衡日志中添加了Event Hub名称，提供更多上下文信息
   • 便于在复杂环境中进行问题诊断

3. 依赖项更新：

   • 将Microsoft.Azure.Amqp依赖更新至2.6.9版本
   • 包含了多个错误修复，提升了底层AMQP协议的稳定性

升级建议

对于正在使用地理数据复制功能的用户，强烈建议升级到5.12.0版本，并开始迁移到新的字符串类型偏移量API。虽然旧版long类型偏移量API目前仍可使用，但考虑到未来的兼容性和功能支持，迁移到新版API是最佳选择。

对于不使用地理数据复制功能的用户，虽然可以继续使用现有代码，但也建议逐步迁移到新版API，以获得更好的长期支持和稳定性。