脉冲星GoClient相当于unacked_messages_timeout_ms

Question

在 Pulsar Python 客户端中，有订阅者选项来设置间隔，在此间隔之后，未被识别的消息将被重新传递。unacked_messages_timeout_ms

脉冲星Go客户端的等效物是什么？

蟒

py_consumer = client.subscribe(

    topic='my-topic',

    subscription_name="py-subscriber",

    unacked_messages_timeout_ms=10000,

    consumer_type=pulsar.ConsumerType.Shared

    )

戈朗

go_consumer, err := client.Subscribe(

    pulsar.ConsumerOptions{

    Topic: "my-topic",

    SubscriptionName: "go-subscriber",

    Type: pulsar.Shared,

    unacked_messages_timeout_ms ????

})

我在这里找不到任何东西：https://pkg.go.dev/github.com/apache/pulsar-client-go/pulsar#ConsumerOptions

如果它不存在，如何配置重新交付间隔以及默认值是什么？

在Github问题中也提出了同样的问题：https://github.com/apache/pulsar-client-go/issues/608

Answer 1

“未识别的消息超时”是很久以前引入的已弃用功能。最近，我们添加了“负 acks”的概念，为应用程序提供了一种处理消息处理失败的简单方法。由于 Go 客户端是在负 ack 可用时编写的，因此我们决定不在其中引入已弃用的功能。