googleapis / googleapis/java-pubsublite

Synchronous Pull

オープン
#372 コメント 1 件 リアクション 0 件 担当者 0 名 GitHub で見る
api: pubsublite priority: p3 type: feature request
主要言語
Java
スター
42
フォーク
27
PR マージ指標
30日以内にマージされた PR はありません

説明

Based in [some comments in this PR](https://github.com/GoogleCloudPlatform/pubsub/pull/243) with @dpcollins-google, I opened this Feature request. Pub/sub provides an option to retrieve records synchronously: https://cloud.google.com/pubsub/docs/reference/rpc/google.pubsub.v1#pullrequest

It isn't the recommended way but it works well in some scenarios.

Pub/Sub Lite doesn't have this feature so if you need to do polling, some buffer is needed in the middle to simulate that behavior. That already happen in the [PubSub Lite kafka library](https://github.com/googleapis/java-pubsublite-kafka) and the Apache Beam connector. It will happen again in the Source kafka connector.

To avoid to repeat the same workaround in each place, it would be nice to provide that API as part of the Java SDK. It would help also to clients moving from PubSub Lite to PubSub and viceversa.

コントリビューションガイド

コントリビューションガイドを開く

調査の方向性

まず、issue にリンクされている Pub/Sub PullRequest リファレンスと、リンクされている Pub/Sub Lite Kafka および Apache Beam の実装を読んで、ポーリングの回避策を理解します。同期取得に関する Java SDK API とその動作を定義し、その後、クライアントが中間バッファを複製せずにそれを使用できることを検証します。

索引モデルが issue の本文から書いたものです。

評価

技術スタック
java
領域
api
issue の種類
機能追加
難易度
5/5
見積もり時間
1週間以上
活発さ
停滞
明瞭さ
おおむね明確
初心者へのやさしさ
35/100

新しい issue をメールで受け取る

初心者向けの GitHub issue を短くまとめたダイジェスト。