Java对接GCP Pub/Sub实现未确认消息重试需要哪些配置？

问题根因 #

你遇到的未确认消息不自动重发的核心原因是GCP Pub/Sub Java客户端的默认行为：只要消息还在客户端内存中且没有被显式调用ack()/nack()，客户端会自动定期向服务端申请延长消息的确认截止时间，默认最长可延长1小时，服务端会一直认为消息还在处理中，因此不会触发重发。

所需的配置修改 #

1. 客户端设置最大确认扩展时长 #

创建Subscriber时显式添加setMaxAckExtensionPeriod配置，该参数控制客户端最多自动为消息延长确认时间的上限，超过该时长后客户端会停止延期，待订阅设置的确认截止时间到期后，服务端就会自动重发消息。
修改后的创建代码示例：

subscriber = Subscriber.newBuilder(subscriptionName, receiver)
    .setExecutorProvider(getExecutorProvider())
    // 可根据业务处理需要调整时长，示例为最多自动延长10分钟
    .setMaxAckExtensionPeriod(Duration.ofMinutes(10))
    .build();

2. 匹配控制台的确认截止时间配置 #

你在GCP控制台设置的订阅*确认截止时间（Ack Deadline）*是服务端单次等待确认的时长，建议设置为单条消息平均处理时长的1.5~2倍，和上述客户端参数配合使用即可达到预期的自动重发效果。

3. 建议显式添加确认逻辑 #

业务代码中建议主动处理ack/nack，避免不必要的等待：处理成功调用consumer.ack()确认消息，处理失败调用consumer.nack()可立即触发重发，不需要等到确认截止时间到期。修改后的MessageReceiver示例：

@Service
public class MyMessageReceiver implements MessageReceiver {
    @Override
    public void receiveMessage(PubsubMessage message, AckReplyConsumer consumer) {
        try {
            System.out.println(message.getMessageId());
            // 你的业务处理逻辑
            consumer.ack();
        } catch (Exception e) {
            // 处理失败直接nack触发即时重发
            consumer.nack();
        }
    }
}

可选优化：配置死信队列 #

为了避免处理失败的消息无限重发，建议在控制台订阅配置中开启死信队列，设置最大重发次数，超过重试次数的消息会被转发到死信队列，方便后续排查异常消息。

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