unacked_messages_timeout_ms 的 Pulsar GoClient 等价物（py-client）

Question

在 Pulsar Python 客户端中，有订阅者选项 unacked_messages_timeout_ms 来设置未确认的消息将被重新传送的时间间隔。

Pulsar Go Client 中的等效项是什么？

Python

py_consumer = client.subscribe(
    topic='my-topic',
    subscription_name="py-subscriber",
    unacked_messages_timeout_ms=10000,
    consumer_type=pulsar.ConsumerType.Shared
    )

Golang

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 Issues too: https://github.com/apache/pulsar-client-go/issues/608

Answer 1

“unacked 消息超时”是很久以前引入的一种已弃用的功能。

最近我们添加了“否定确认”的概念，以便为应用程序提供一种处理消息处理失败的简单方法。

由于 Go 客户端是在负面确认已经可用时编写的，我们决定不在其中引入已弃用的功能。

unacked_messages_timeout_ms 的 Pulsar GoClient 等价物（py-client）

Pulsar GoClient Equivalent of unacked_messages_timeout_ms (py-client)

python

go

apache-pulsar

python-pulsar