如何让新建的Azure Event Hub消费组忽略旧消息，仅处理创建后数据？

以下是几种可行的实现方案，按推荐优先级排序：

1. 客户端显式指定消费起始位置（最直接） #

所有主流Azure Event Hub SDK都支持在初始化消费者时，指定从当前时间点开始消费，而非默认的最早可用消息：

• .NET SDK示例：

  var consumer = new EventHubConsumerClient(
      "新消费组名称",
      "Event Hub连接字符串",
      "Event Hub名称",
      EventPosition.FromEnqueuedTime(DateTimeOffset.UtcNow)
  );
  

• Java SDK示例：

  EventHubConsumerAsyncClient consumer = new EventHubClientBuilder()
      .connectionString("Event Hub连接字符串", "Event Hub名称")
      .consumerGroup("新消费组名称")
      .eventPosition(EventPosition.fromEnqueuedTime(Instant.now()))
      .buildAsyncConsumerClient();
  

• Python SDK示例：

  from azure.eventhub import EventHubConsumerClient, EventPosition
  from datetime import datetime
  
  consumer = EventHubConsumerClient(
      connection_str="Event Hub连接字符串",
      consumer_group="新消费组名称",
      eventhub_name="Event Hub名称"
  )
  # 消费时指定起始位置
  with consumer:
      consumer.receive(
          on_event=on_event_callback,
          starting_position=EventPosition.from_enqueued_time(datetime.utcnow())
      )
  

这种方式无需修改Event Hub服务端配置，完全由客户端控制，不会影响其他消费组，适合高负载场景下平稳启动新消费组。

2. 手动初始化消费组检查点 #

创建新消费组后，先启动一个临时消费者，直接为所有分区设置当前时间对应的检查点，之后正式消费者会从该检查点开始消费：

1. 遍历Event Hub的所有分区；
2. 对每个分区，获取当前时间对应的消息偏移量；
3. 调用检查点API（如.NET的UpdateCheckpointAsync、Java的updateCheckpoint）将该偏移量设为检查点；
4. 关闭临时消费者，启动正式消费者即可。
   注意：如果Event Hub分区数量较多，需要确保遍历所有分区完成检查点初始化，避免遗漏分区的历史消息。

3. 基于捕获功能的间接方案（仅适用于已开启捕获的场景） #

如果你的Event Hub已经配置了捕获到存储账户的功能，可以让新消费组直接从捕获的最新文件开始消费，跳过之前的历史捕获数据。这种方案依赖已有的捕获配置，适合原本就需要持久化消息的场景。

注意事项 #

• 务必确认SDK默认的起始位置：多数SDK默认会从Earliest（最早可用消息）开始消费，必须显式修改为当前时间的起始位置；
• 高负载Event Hub下，优先选择方案1，避免临时消费者初始化检查点时占用额外资源。

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