脉冲星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 可用时编写的，因此我们决定不在其中引入已弃用的功能。