Pub/Sub c++ client: How to prevent/reduce ack failures on at least once delivery subscription
メンテナーはふだん 1 日以内に返信
まだ誰も着手していません。
評価
- 難易度
- 4/5
- 見積もり時間
- 3〜5日
- 初心者へのやさしさ
- 30/100
- issue の種類
- バグ
- 明瞭さ
- おおむね明確
- 活発さ
- 停滞
- 技術スタック
- cpp, google-cloud
調査の方向性
まず google/cloud/pubsub/internal/ack_handler_wrapper.cc:29 とレポートに記載されたクライアント設定を調べ、次に説明されている負荷テストで失敗を再現します。UNAVAILABLE エラーと再配信に関連する acknowledgement および deadline-extension の動作を追跡します。ack の失敗と再配信の遅延の原因が特定され、それらを軽減または防止する検証済みの方法が得られれば完了です。
索引モデルが issue の本文から書いたものです。
説明
Client version: v2.39.0
MaxDeadline = seconds(0) (default value)
MaxDeadlineExtension = seconds(180)
MinDeadlineExtension = seconds(60)
MaxOutstandingMessages = 250
MaxConcurrency = 1
Time to time acks are failing. There is no retry for at least once delivery. How to reduce/prevent these failures? It happens 10-20 times a day.
Some of the logged errors [file_name] - [message]
[NTPubSubLogger] /google-cloud-cpp/google/cloud/pubsub/internal/ack_handler_wrapper.cc:29 - error while trying to ack(), status=UNAVAILABLE: recvmsg:Connection reset by peer
[NTPubSubLogger] /google-cloud-cpp/google/cloud/pubsub/internal/ack_handler_wrapper.cc:29 - error while trying to ack(), status=UNAVAILABLE: 502:Bad Gateway
It sounds like network issue but I doubt that. It happens every day 10-20 times. I can reproduce it with a 10 minutes of load tests by consuming/processing 300 messages per second.
Messages are ordered by account id in the system. When this happens the messages are stuck on pub/sub for 10-20 minutes because of unacked message. initial deadline=60 seconds, max deadline = 180 seconds. I observed the cpp client logs in debug mode. There is no ModifyAckDeadlineRequest is being made but still messages redelivered between 10-20 minutes later, in fact they should arrive in a few minutes. (That's another issue and maybe not related to the client.)
- 主要言語
- C++
- スター
- 659
- フォーク
- 471
- 平均マージ
- 1日 10時間
- マージ済み PR(30日)
- 100
環境構築
- Dockerfile・Docker Compose ファイルなし
- プルリクエストのテンプレートなし
- コントリビューションガイドを読む
はじめの一歩
- issue を最後まで読み、次にプロジェクトのコントリビューションガイドを読みます。
- 着手することを issue にコメントします — 二人が同じ作業をするのを防げます。
- リポジトリをフォークし、ブランチを切って変更します。
- issue 番号を参照したプルリクエストを送ります。
googleapis/google-cloud-cpp のほかの issue
-
cleanup(storage): remove deprecated OpenTelemetry rpc.message.type and rpc.message.id attributesオープンapi: storage type: cleanup
難易度 2/5 1〜3時間 初心者へのやさしさ 76/100
googleapis/google-cloud-cpp#16544 ·
メンテナーはふだん 1 日以内に返信
-
api: storage priority: p2 type: bug
難易度 2/5 1〜3時間 初心者へのやさしさ 82/100
googleapis/google-cloud-cpp#16529 ·
メンテナーはふだん 1 日以内に返信
-
type: feature request
難易度 2/5 1〜3時間 初心者へのやさしさ 73/100
googleapis/google-cloud-cpp#16193 ·
メンテナーはふだん 1 日以内に返信
-
api: storage type: cleanup
難易度 3/5 1〜2日 初心者へのやさしさ 55/100
googleapis/google-cloud-cpp#16545 ·
メンテナーはふだん 1 日以内に返信
-
api: storage type: cleanup
難易度 3/5 1〜2日 初心者へのやさしさ 68/100
googleapis/google-cloud-cpp#16404 ·
メンテナーはふだん 1 日以内に返信
googleapis/google-cloud-cpp の issue をすべて見る
似ている issue
-
bug derived types format I/O medium priority semantics
難易度 2/5 1〜3時間 初心者へのやさしさ 78/100
メンテナーはふだん 1 日以内に返信
-
Incorrect Link in README.md対応中かも このイシューにリンクされたプルリクエストがオープン中、またはマージ済みです。 オープン
難易度 1/5 1時間未満 初心者へのやさしさ 95/100
flameshot-org/flameshot#4996 ·
メンテナーはふだん 2 日以内に返信
-
難易度 2/5 1〜3時間 初心者へのやさしさ 64/100
utopia-rise/godot-jvm#1004 ·
メンテナーはふだん 1 日以内に返信
-
難易度 2/5 1〜3時間 初心者へのやさしさ 70/100
メンテナーはふだん 3 日以内に返信
-
難易度 2/5 1〜3時間 初心者へのやさしさ 70/100
メンテナーはふだん 1 日以内に返信