如何通过subscribeAndConvert设置GCP Pub/Sub的Ack Mode？

使用以下代码创建订阅者十分简洁：

pubSubTemplate.subscribeAndConvert( subs, { message ->
...

但能否通过这种方式设置Ack Mode？

我了解使用通道适配器（个人认为不够简洁，因此探索subscribeAndConvert方案）可实现该设置，示例如下：

adapter.setAckMode(AckMode.MANUAL);

Spring Cloud Stream也有对应的配置项：

spring.cloud.stream.gcp.pubsub.default.consumer.ack-mode: AUTO_ACK

直接通过pubSubTemplate.subscribeAndConvert()的重载方法无法直接指定Ack Mode，但可以通过两种方式间接实现：

方式一：自定义订阅者工厂（SubscriberFactory） #

先创建配置好Ack Mode的订阅者工厂，再注入到PubSubTemplate中：

@Bean
public SubscriberFactory customSubscriberFactory() {
    DefaultSubscriberFactory factory = new DefaultSubscriberFactory();
    factory.setAckMode(AckMode.MANUAL);
    // 可按需添加其他订阅者配置，比如并发处理数
    return factory;
}

使用时将自定义工厂设置到PubSubTemplate：

@Autowired
private SubscriberFactory customSubscriberFactory;

// 初始化或调用时设置
pubSubTemplate.setSubscriberFactory(customSubscriberFactory);
pubSubTemplate.subscribeAndConvert(subs, message -> {
    // 手动ACK示例
    message.getAcknowledgement().ack();
    // 消息处理逻辑
});

方式二：全局配置属性 #

通过配置文件统一设置所有PubSubTemplate创建的订阅者的Ack Mode，无需修改代码：

spring.cloud.gcp.pubsub.subscriber.ack-mode: MANUAL

该配置会全局生效，所有通过PubSubTemplate生成的订阅者都会使用指定的Ack Mode。

总结 #

• subscribeAndConvert方法本身不支持直接传入Ack Mode参数，但可通过上述两种方式实现配置
• 全局配置更简洁，适合统一规则；自定义工厂则更灵活，可针对单个订阅者做特殊配置

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