0

在 Pulsar Python Client 中，有一个订阅者选项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
    )

戈朗

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

4

1 回答 1

2

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

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

由于 Go 客户端是在否定 ack 已经可用时编写的，因此我们决定不在那里引入已弃用的功能。

于 2021-09-09T22:19:06.527 回答