在 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
1 回答

蕭十郎
TA貢獻1815條經驗 獲得超13個贊
“未識別的消息超時”是很久以前引入的已棄用功能。
最近,我們添加了“負 acks”的概念,為應用程序提供了一種處理消息處理失敗的簡單方法。
由于 Go 客戶端是在負 ack 可用時編寫的,因此我們決定不在其中引入已棄用的功能。
- 1 回答
- 0 關注
- 91 瀏覽
添加回答
舉報
0/150
提交
取消