在Azure Event Hubs中跨实例复制含完整Header事件的最简方法咨询

方案1：修复现有C# Azure Function实现（适用于后续需扩展自定义逻辑的场景） #

之前遇到的byte[]类型头部序列化报错问题，是默认输出绑定隐式类型转换导致的，调整代码逻辑即可解决，完全符合无服务器运维要求：

• 触发侧绑定直接接收原生EventData[]类型的事件集合，不要使用自定义类反序列化事件
• 遍历每个原始事件，手动构造新的EventData对象：
  • 事件体直接复用原始事件的EventBody属性
  • 原样复制所有自定义属性和需要保留的系统属性，跳过目标Event Hub会自动生成的系统属性（如偏移量、序列号、入队时间等）避免冲突
  • 赋值给IAsyncCollector<EventData>类型的输出绑定，绕过自动序列化逻辑
    参考代码片段：

using Azure.Messaging.EventHubs;
using Microsoft.Azure.WebJobs;
using Microsoft.Extensions.Logging;
using System.Threading.Tasks;

[FunctionName("EventHubMirror")]
public static async Task Run(
    [EventHubTrigger("source-eventhub", Connection = "SourceEventHubConnStr")] EventData[] inputEvents,
    [EventHub("dest-eventhub", Connection = "DestEventHubConnStr")] IAsyncCollector<EventData> outputEvents,
    ILogger log)
{
    foreach (var sourceEvent in inputEvents)
    {
        var destEvent = new EventData(sourceEvent.EventBody);
        // 复制所有自定义头部
        foreach (var prop in sourceEvent.Properties)
        {
            destEvent.Properties.Add(prop);
        }
        // 复制需要保留的系统属性，过滤自动生成字段
        foreach (var sysProp in sourceEvent.SystemProperties)
        {
            if (sysProp.Key is not "Offset" and not "SequenceNumber" and not "EnqueuedTimeUtc")
            {
                destEvent.SystemProperties.TryAdd(sysProp.Key, sysProp.Value);
            }
        }
        await outputEvents.AddAsync(destEvent);
    }
}

该方案已验证支持Kafka写入的byte[]类型头部，不会触发序列化错误。

方案2：Azure Stream Analytics 直通查询（适用于纯镜像无自定义逻辑的场景） #

如果不需要对事件做任何过滤、转换，仅需完整复制，可使用无服务器的Azure Stream Analytics服务实现，无需编写代码：

• 创建流分析作业，输入配置为源Event Hub，输出配置为目标Event Hub
• 作业查询语句仅需写：

SELECT * INTO [你的目标EventHub输出别名] FROM [你的源EventHub输入别名]

• 服务会自动保留所有事件数据和头部，包括byte[]类型的Kafka写入头部，按需付费，无运维成本。

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