Tag: google-cloud-pubsub

How to publish a Pub/Sub message with a Supplier bean?

I want to publish a Pub/Sub message in Spring according to the Google documentation (see https://cloud.google.com/pubsub/docs/spring#publishing-messages-using-stream-binder). The only problem is that I am new to Spring Framework and I have no idea of how to turn this example into something that I can use. That is, a method that allows me to send a specific message from a service to

org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name ‘messageSender’

Error while trying to publish a message from spring boot to Google cloud platform pub/sub. I was trying to publish a message to the Google Cloud Platform pub/sub messaging queue. I was getting the following errors while trying to run the application.Please help. I was using only a single Java Class file. Thease are my dependencies(pom.xml) Please help. Thank you.

Ways to implement Google Pub Sub

I found these 3 ways for implementing messaging with Google Pub Sub: with client libraries https://cloud.google.com/pubsub/docs/publisher with spring integration message channels and PubSubTemplate API https://dzone.com/articles/spring-boot-and-gcp-cloud-pubsub without message channels but with PubSubTemplate API https://medium.com/bb-tutorials-and-thoughts/gcp-how-to-subscribe-and-send-pubsub-messages-in-spring-boot-app-b27e2e8863e3 I want to understand the differences between them / when each is best to use and which would be useful for my case. I have to implement

i.grpc.internal.AbstractClientStream – Received data on closed stream meaning

I have a Spring boot application (v2.2.10.RELEASE) that subscribes to multiple topics in pubSub and pulls async data and sends it to somewhere else. I am not using SpringGCP, just native google libraries this is my subscriber setting: With high traffic and big messages (2 – 4 kb) I encounter this info message: first of all, I don’t fully understand

Kafka Connect: Convert message from bytes to Json

I am trying to use a Google PubSub source connector to fetch data from my google cloud to kafka. I do get the data, but the message comes as bytes. I refered here and as mentioned, I have used a JSON convertor to change it. Here is my connector code part: And this what I get in my kafka: Even

Google PubSub and duplicated messages from the TOPIC

How to prevent duplicated msg from happening in Google Cloud PubSub? Say, I have a code that handles the msg that it is subscribed for. Say, I have 2 nodes with the same Service that has this code. Once one has received the msg but not yet acknowledged it, another node will receive the same message. And this is where