google-cloud-pubsub

1熱

1答えて

私はKryoシリアル化でSpark 2.0.2を使用しています。私は、SparkストリーミングにグーグルのPubSubからのメッセージを摂取するためのカスタム受信機を実装しようとしています： class PubSubReceiver(project: String, topic: String, subscription: String) extends Receiver[Array[

3熱

1答えて

pubsubエミュレータでのトピックの作成

私は基本的な実装をテストするためにpubsubエミュレータを使い始めましたが、新しいトピックを作成しようとすると問題が発生しました。私のエミュレータは、ローカルホスト上でリッスン：8085と私はAPIを介してトピックを作成する場合 PUT http://localhost:8085/v1/projects/testproject/topics/test すべてが正常に動作してトピックが作成さ

1熱

1答えて

Typescript import @ google-cloud/pubsub

Type-Script以外のモジュールをTypeScriptプロジェクトにインポートします。このプロジェクトには独自の宣言や@types宣言がありません。そのため、私は自分の宣言をモジュール用に作成しました。私は宣言ファイル内のモジュールを宣言するときしかし、私は次のエラーを取得する： import stream from 'stream' import events from 'events

2熱

1答えて

Google Cloud Pub/Sub Snapshotとは何ですか？

すべてのPub/Subドキュメントを読み、スナップショットについては何も言及していません。 https://googlecloudplatform.github.io/google-cloud-node/#/docs/pubsub/0.11.0/pubsub/snapshot 許：私はNode.jsのクライアントライブラリのドキュメントを読んだときはしかし、私は、スナップショットオブジェクトへの

0熱

1答えて

SubscriberClient.pull - リクエストをキャンセルする方法は？文書によると

公共最終PullResponseプル（SubscriptionNameサブスクリプション、ブールreturnImmediately、int型maxMessages）に：このフィールドをtrueに設定した場合 @param returnImmediately、システムは、メッセージがない場合でも、すぐに対応させていただきますPullレスポンスに戻ることができます。そうしないと、システムは、メッセー

9熱

2答えて

URLエンドポイントへのサブスクリプションを作成するときに「pubsub error INVALID_ARGUMENT」

GC pubsubでテストトピックを作成し、プルサブスクリプションを作成することはできますが、URLエンドポイントサブスクリプションを作成しようとするとすぐに「pubsubエラーINVALID_ARGUMENT」のparams サブスクリプション名：testingsub エンドポイントURL：私が間違っているの何任意のアイデアが

0熱

1答えて

GoogleのPubSubの加入者startAsync NosuchmethodError

は、私は次のように定義された加入者を持っている：subscriber.startAsyncを呼び出すとき class PubSubMessageReceiver extends MessageReceiver { override def receiveMessage(message: PubsubMessage, consumer: AckReplyConsumer): Unit =

6熱

1答えて

Google Cloudは、成功したばかりのPub/Subを応答する機能を提供します。

Pub/Subでトリガされたクラウド機能を使用して、電子メールの配信を確実にしています。エラーが発生する前に、電子メールサービスが応答するまでに時間がかかり、クラウド機能が終了することがあります。メッセージは既に承認されているので、私たちの電子メールは失われます。私たちが呼び出されると、クラウド機能はPub/SubメッセージにACKを自動的に送信しているようです。私たちのコードが正常に完了するま

0熱

2答えて

java.lang.NoSuchMethodError：com.google.common.util.concurrent.MoreExecutors.platformThreadFactory（）Ljava/util/concurrent/ThreadFactory;

実際に私は雲のパブ/サブのトピックを取得しようとしています。私は、上記のエラーが発生しているトピックを取得するためにリクエストURLを送信するとき、安らかなWebサービスでコードを書いています。いくつかのルックアップの後、pub/sub 0.17バージョンとguava 19.oバージョンのバージョンの競合のような縫い目がありますが、私はグアバ19バージョンを除外し、18バージョンを追加しました。し

2熱

1答えて

メッセージが失われ、GCP Pubsubで重複しています

DataflowからGCP PubSubを読んで問題が発生しました。多数のメッセージを短時間で公開すると、一部のメッセージが失われることを除いて、Dataflowは送信されたメッセージのほとんどを受信しますいくつかの他のメッセージは複製されます。そして、最も奇妙な部分は、失われたメッセージの数が複製されるメッセージの数とまったく同じになるということです。例では、5秒間に4,000のメッセージを送