如何在 C# 中为事件总线创建接收器以获取给定时间跨度的消息？

Question

using Azure.Messaging.EventHubs.Consumer;
using System.Text;

string connectionString = "";
string eventHubName = "";
string consumerGroup = EventHubConsumerClient.DefaultConsumerGroupName;

await using (var consumerClient = new EventHubConsumerClient(consumerGroup, connectionString, eventHubName))
{
  await foreach (PartitionEvent partitionEvent in consumerClient.ReadEventsAsync())
  {
    string json = Encoding.UTF8.GetString(partitionEvent.Data.Body.ToArray());
    Console.WriteLine(json);
  }
}

这当前返回来自 eventHub 的所有消息。我只需要收到最近 1 小时的消息，然后停止收听新消息。