Questions tagged [spring-pulsar]
14 questions
2
votes
1 answer
How to use Apache Pulsar with Spring Cloud Stream?
There is no official library of Apache Pulsar for Spring Cloud Stream.
I found Spring for Apache Pulsar, but it is only about Spring Boot.
In it's GitHub repository, there is a [spring-pulsar-spring-cloud-stream-binder], but not found in…
user10200598
- 31
- 3
2
votes
2 answers
Custom Objects with Apache Pulsar and Spring Boot
I'm using Apache Pulsar for the first time but finding it hard to publish and listen to custom objects. I have defined schemas as directed by this reference pages but for some reason it’s not working.
@SpringBootApplication
public class…
Keshavram Kuduwa
- 942
- 10
- 40
1
vote
1 answer
Spring boot org.apache.pulsar.client.api.Message.getValue() seems to lock any line of code it's included in. How do I stop it from doing this?
I am using spring boot to connect to a Pulsar message broker but I cannot access the message payload no matter what class I use in the call to:
//...
void listen( message)
//...
I'm using Intellij 2023.1 (Community edition)
The full class code…
Dan
- 45
- 4
1
vote
2 answers
Multithreaded Use of Spring Pulsar
I am working on a project to read from our existing ElasticSearch instance and produce messages in Pulsar. If I do this in a highly multithreaded way without any explicit synchronization, I get many occurances of the following log line:
Message with…
Jeff
- 101
- 1
- 6
1
vote
1 answer
Spring Pulsar listener does not receive messages
Edit: the issue was that my @PulsarListener was in a class that was not a Spring Bean, and as such did not get discovered. Adding a @Service annotation solved the problem.
I'm in a Spring Boot 3.0.1 project and using version 0.1.1-SNAPSHOT of…
Marcus Hellberg
- 1,853
- 10
- 16
0
votes
0 answers
Issue with Pulsar GeoReplication
I have followed the steps and completed the Geo replication setup as per the pulsar documentation
https://pulsar.apache.org/docs/3.1.x/administration-geo/
All the geo replication related setup was enabled and working fine.
When I try to produce a…
0
votes
2 answers
Pulsar client numIoThreads and numListenerThreads per consumer instance or for all consumer instances
Let's say I have the following pulsar config:
pulsar:
topicX:
client:
config:
numIoThreads: 3
numListenerThreads: 15
consumer:
config:
receiverQueueSize: 20
count: 3
topicY:
client:
…
Thomas Verhoeven
- 238
- 3
- 16
0
votes
1 answer
How to consume JSON object in Apache Pulsar using spring-pulsar-spring-boot-starter?
I am trying to implement a simple messaging queue using Spring Boot and Apache Pulsar. The system works fine when working with String datatype but not for a Custom Object. Below are the object I'm using as well as the producer and consumer:
Custom…
Neha P
- 13
- 7
0
votes
1 answer
spring-pulsar minimum spring boot version?
The documentation for spring-pulsar contains a table documenting the compatibility matrix of supported technology versions.
At the time this question is being asked, it states that the minimum Spring Boot version is 3.2.0. But when I look at…
axiopisty
- 4,972
- 8
- 44
- 73
0
votes
1 answer
How to modify the producer cache properties for Spring Pulsar 0.2.0 producer?
Spring Pulsar 0.2.0
how to modify ProducerConfigProperties.cache parameter
i want to change cache properties through application.properties, such…
DeveloperV
- 3
- 1
0
votes
1 answer
Pulsar Spring Boot Cannot get DNS TTL settings from sun.net.InetAddressCachePolicy
I am trying to initialize PulsarClient in spring-boot's configuration class using the following code but getting
Java Details:
20
3.0.0
…
silentsudo
- 6,730
- 6
- 39
- 81
0
votes
0 answers
with spring cloud stream binding to pulsar the dead letter policy doesn't apply to the consumer
I am using spring cloud stream bindings to consume pulsar messages with. implementation("org.springframework.pulsar:spring-pulsar-spring-cloud-stream-binder:0.1.1-SNAPSHOT") this library is used.
Following is the application.yaml configuration.
#…
Noor Khan
- 151
- 1
- 9
0
votes
1 answer
How to send JsonArray data in apache-pulsar-client?
I am a beginner who just started developing pulsar-client with spring boot.
First of all, I learned the basics through pulsar doc and git, but I was stuck testing batch transmission of messages from the pulsar-client producer.
In particular, I want…
Hyungin Cho
- 25
- 4
0
votes
1 answer
Defining multiple Pulsar Producers in Spring Boot application
We have a SpringBoot application that sends messages into multiple topics, each with a defined JSON Schema. I would like to reduce the boilerplate code so that we don't have to call setSchema on the PulsarTemplate instance when the defined type…
Gootik
- 526
- 1
- 7
- 18