Pulsar Go客户端对应Python unacked_messages_timeout_ms的等效配置查询
Pulsar Go客户端未确认消息超时重发配置说明
- 等效参数:Pulsar Go客户端中与Python客户端
unacked_messages_timeout_ms功能对应的配置项为 NackRedeliveryDelay,属于ConsumerOptions结构体的原生字段。该参数接收time.Duration类型的值,用于定义未确认消息/被否定确认消息的重发间隔。 - 正确代码示例:
import "time" go_consumer, err := client.Subscribe(pulsar.ConsumerOptions{ Topic: "my-topic", SubscriptionName: "go-subscriber", Type: pulsar.Shared, NackRedeliveryDelay: 10 * time.Second, // 等效Python端10000ms的配置效果 })
- 默认值:该参数默认值为1分钟(
60 * time.Second) - 补充说明:如果需要实现未确认消息自动超时触发重发的逻辑,可同时开启客户端未确认消息追踪能力,追踪器会自动扫描超时未确认的消息,按
NackRedeliveryDelay指定的间隔触发重发。
内容的提问来源于stack exchange,提问作者Shubham Jain
相关产品推荐
相关产品推荐

