Category "google-cloud-pubsub"

Issues streaming data from Pub/Sub into BigQuery using Dataflow and Apache Beam (Python)

currently I am facing issues getting my beam pipeline running on Dataflow to write data from Pub/Sub into BigQuery. I've looked through the various steps and al

Problem with Google Cloud Pub/Sub API and Spring boot application

I write spring boot application for subscribing Google cloud Pub/Sub topic for this I use Google's tutorial, but when I run application I have get this error

Google Cloud Platform - Pub/Sub push to private (VPN) on-premise listeners?

Official documentation for Pub/Sub service states that Push is available to listeners that are available on public network: An HTTPS server with non-self-si

Missing necessary OAuth permissions on GCP Pub/Sub

I'm trying to follow this guide here to get push notifications whenever a response has been submitted on a Google Forms form. All prerequisites have been comple

Pull message in Google cloud pub/sub getting blank message body

I published a message in a topic and then in the google cloud, clicked on subscriptions, clicked on one of the subscriptions, and then clicked on the pull. I di

Google Pub Sub/Lite vs RabbitMQ

I would like to confront my understanding of google pubSub/lite vs RabbitMQ (using MQTT over WSS). My use case is that I need something like a topic exchange. T

Retry on Firebase functions with pubsub

I am using firebase functions with pubsub. The functions are invoked every time there is an incoming message (push) I am looking at incorporating retry mechanis

Google Cloud: Pubsub subscription filter expression options

I am trying to put filter in the GCP pubsub subscription. My requirement is to add number of codes in the filter. I am using terraform for that. Here is somethi

Push GCP PubSub events to Cloud Datastore

I'm using GCP pub sub topics to store specific events in my applications and then have custom code running based on topic subscriptions fire to process db trans

Restarting inifinite Flux on error with pubSubReactiveFactory

I'm developing an application which uses reactor libraries to connect with Google pubsub. So I have a Flux of messages. I want it to always consume from the que