You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

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

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.10.05 22:21:02