亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

為了賬號安全,請及時綁定郵箱和手機立即綁定
已解決430363個問題,去搜搜看,總會有你想問的

脈沖星GoClient相當于unacked_messages_timeout_ms

脈沖星GoClient相當于unacked_messages_timeout_ms

Go
30秒到達戰場 2022-09-26 19:37:41
在 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 可用時編寫的,因此我們決定不在其中引入已棄用的功能。


查看完整回答
反對 回復 2022-09-26
  • 1 回答
  • 0 關注
  • 91 瀏覽
慕課專欄
更多

添加回答

舉報

0/150
提交
取消
微信客服

購課補貼
聯系客服咨詢優惠詳情

幫助反饋 APP下載

慕課網APP
您的移動學習伙伴

公眾號

掃描二維碼
關注慕課網微信公眾號