首先得明确：Azure Service Bus和Kafka的消息跟踪逻辑有点不一样，它是靠**消费者组（队列场景）或订阅（主题场景）**来维护消息读取进度的。默认情况下，同一个组/订阅的消费者重启后会从上次中断的位置继续读，新加入的订阅者也只能获取订阅创建后的新消息。要实现你要的“每次启动都拿到A、B、C，新订阅者也能获取历史消息”的效果，可以从这几个方向修改：

1. 用动态唯一的消费者组（队列场景） #

如果你用的是Service Bus队列，每次启动消费者时生成一个独一无二的消费者组名，相当于每次都是一个全新的“读者”，Service Bus会让这个新组从头开始读取所有历史消息。

比如在你的Spring Boot代码里，创建Processor Client的时候动态生成组名：

@Bean
public ServiceBusProcessorClient queueProcessor(ServiceBusClientBuilder clientBuilder) {
    // 用UUID生成唯一消费者组名
    String uniqueConsumerGroup = UUID.randomUUID().toString();
    
    return clientBuilder.processor()
        .queueName("你的队列名称")
        .consumerGroup(uniqueConsumerGroup) // 使用动态组名
        .processMessage(context -> {
            // 你的消息处理逻辑，比如打印消息内容
            System.out.println("收到消息：" + context.getMessage().getBody().toString());
        })
        .processError(errorContext -> {
            // 错误处理逻辑
            System.err.println("消息处理出错：" + errorContext.getException().getMessage());
        })
        .buildProcessorClient();
}

2. 创建动态订阅并设置从头读取（主题场景） #

如果用的是Service Bus主题，那每次启动时创建一个新的订阅，并且指定订阅从主题的起始位置开始读取，这样新订阅会自动拉取所有历史消息。

可以加个初始化方法来创建动态订阅：

@Bean
public ServiceBusAdministrationClient adminClient() {
    return new ServiceBusAdministrationClientBuilder()
        .connectionString("你的Service Bus连接字符串")
        .buildClient();
}

@PostConstruct
public void createDynamicSubscription() {
    String topicName = "你的主题名称";
    // 生成唯一订阅名
    String uniqueSubscription = "dynamic-sub-" + UUID.randomUUID();
    
    if (!adminClient().subscriptionExists(topicName, uniqueSubscription)) {
        CreateSubscriptionOptions options = new CreateSubscriptionOptions();
        options.setStartFromBeginning(true); // 关键：让订阅从主题开头读取所有历史消息
        adminClient().createSubscription(topicName, uniqueSubscription, options);
    }
    
    // 之后用这个唯一订阅名创建Processor Client
}

然后创建Processor Client时使用这个动态订阅名，就能每次启动都拿到所有历史消息了。

3. 主动重置消费位置（固定组/订阅场景） #

如果必须使用固定的消费者组（队列）或订阅（主题），那可以在消费者启动后，主动调用重置方法，让它回到消息队列/订阅的起始位置。

比如：

@Bean
public ServiceBusProcessorClient fixedGroupProcessor(ServiceBusClientBuilder clientBuilder) {
    ServiceBusProcessorClient processor = clientBuilder.processor()
        .queueName("你的队列名称")
        .consumerGroup("$Default") // 使用固定组名，比如默认组
        .processMessage(context -> {
            // 消息处理逻辑
        })
        .processError(errorContext -> {
            // 错误处理逻辑
        })
        .buildProcessorClient();
    
    // 启动后重置到队列起始位置
    processor.start();
    processor.seekToStartOfQueue();
    
    return processor;
}

⚠️ 注意：这个操作会修改该消费者组的全局偏移，同组的其他消费者也会跟着从开头读，所以多实例部署时要谨慎使用。

4. 补充配置提醒 #

如果你用的是Spring Cloud Azure Starter，注意这些点：

• 不要设置spring.cloud.azure.servicebus.consumer.auto-complete为true后又手动重复完成，避免消息被标记为已读后无法再次获取；
• 动态生成的消费者组/订阅如果不需要长期保留，可以设置autoDeleteOnIdle属性，让Service Bus自动清理闲置的组/订阅，避免资源浪费。

总结一下，最稳妥的方案是动态生成唯一的消费者组（队列）或订阅（主题），这样既不会影响其他消费者，又能保证每次启动都获取所有历史消息，新加入的订阅者也能拿到之前的消息。

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