Azure EventHubs消费端为Push还是Pull模型？与Apache Kafka对比求证

一、模型确认：Event Hubs 采用 Push 模型 #

和 Apache Kafka 的 Pull 模型不同，Azure Event Hubs 消费端采用Push 模型——服务端会主动向处于监听状态的消费者推送事件，而非等待消费者主动轮询拉取。

二、关键细节补充 #

• 主动触发回调：消费者只需通过 SDK 注册事件处理回调（比如 ProcessEventAsync），当 Event Hubs 分区有新事件到达时，服务会自动触发回调并将事件传递给消费者。
• 基于 AMQP 协议实现：底层依赖 AMQP 1.0 建立持久连接，服务通过该连接主动投递事件，无需消费者发起拉取请求。
• 分区级有序推送：每个分区的事件会推送给对应消费组内的唯一消费者实例，严格保证分区内事件的顺序性。
• 流量自适应：服务会根据消费者的处理能力动态调整推送速率，避免因推送过快导致消费者过载。
• 断点续推：若消费者连接中断，恢复后服务会从消费者上次提交的偏移量位置，继续推送未处理的事件。

三、简单验证方法 #

1. SDK 回调监听验证 #

使用 Azure.Messaging.EventHubs SDK 编写极简消费者代码，无需主动调用拉取方法，仅注册事件回调：

using Azure.Messaging.EventHubs;
using Azure.Messaging.EventHubs.Consumer;
using Azure.Messaging.EventHubs.Processor;
using Azure.Storage.Blobs;
using System.Text;

// 替换为你的资源信息
string eventHubConn = "你的Event Hubs连接字符串";
string eventHubName = "你的事件中心名称";
string storageConn = "你的存储账户连接字符串";
string containerName = "你的Blob容器名称";

var blobClient = new BlobContainerClient(storageConn, containerName);
var processor = new EventProcessorClient(blobClient, EventHubConsumerClient.DefaultConsumerGroupName, eventHubConn, eventHubName);

// 注册事件处理回调
processor.ProcessEventAsync += async args =>
{
    Console.WriteLine($"自动接收到事件：{Encoding.UTF8.GetString(args.Data.Body.ToArray())}");
    await args.UpdateCheckpointAsync();
};

processor.ProcessErrorAsync += args =>
{
    Console.WriteLine($"错误：{args.Exception.Message}");
    return Task.CompletedTask;
};

// 启动消费者，无需主动拉取
await processor.StartProcessingAsync();
Console.WriteLine("消费者已启动，等待事件推送...");
Console.ReadLine();
await processor.StopProcessingAsync();

运行代码后，向 Event Hubs 发送测试事件，控制台会自动打印事件内容，证明是服务主动推送。

2. 诊断日志观察 #

开启 Event Hubs 的诊断日志，关注 EventDelivery 类型的日志条目：当有事件产生时，日志会记录服务主动向消费者投递事件的操作，而非消费者发起拉取请求的记录。

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