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. Tha…

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

google-cloud-platform google-cloud-pubsub java spring spring-boot

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. Thea…

Ways to implement Google Pub Sub

google-cloud-pubsub java messaging spring spring-boot

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…

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

google-cloud-pubsub grpc-java java spring-boot

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 m…

Kafka Connect: Convert message from bytes to Json

apache-kafka apache-kafka-connect google-cloud-pubsub java

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

google-cloud-platform google-cloud-pubsub java

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 …