23
questions
0
votes
1
answer
50
views
Spring Pulsar Admin cannot create topic
I tried to use Spring Pulsar to create a topic on an Apache Pulsar instance in the cloud, but after implementing the connection settings, I keep getting the following error: Caused by: org.apache....
0
votes
1
answer
28
views
Configuring Namespace and Tenant for Spring-Pulsar
Is there a way in Spring-Pulsar to change the namespace and tenant? By default, Spring-Pulsar goes to public tenant and default namespace. I want to use a property or application.yml to set a default ...
0
votes
1
answer
32
views
Springboot Pulsar ObjectMapper
We are using Spring pulsar (with SpringBoot) to create and consume JSON messages in Kotlin. However, to better support Kotlin+Json we need to create a custom ObjectMapper. Is it possible to force ...
1
vote
1
answer
38
views
Creating listeners without springboot auto config
I have a usecase where I need to start listeners programmatically based on some configuration at runtime.
I was wondering how to register pulsar listeners at runtime without using the static @...
0
votes
1
answer
31
views
Configure AutoClusterFailover for Pulsar Client
I'm following the documentation of Spring for Apache Pulsar https://docs.spring.io/spring-pulsar/docs/0.1.0-M1/reference/html/#pulsar-client, but I can't find the configuration options for failover ...
0
votes
1
answer
25
views
spring-pulsar-test dependency - missing from maven centrel
This testing documentation for Spring Pulsar Testing Applications mentions a spring-pulsar-test dependency.
I have not been able to find this dependency in Maven Central and my attempts at including ...
0
votes
1
answer
35
views
Is it possible for the topics names set in the @PulsarListener annotation to come from a Spring app properties value?
I am wondering if it is possible to do something like this
@Value("${pulsar.topic.name}")
private String topicName;
@PulsarListener(subscriptionName = "subscription-name",
...
0
votes
1
answer
98
views
How to consume null payloads with spring-pulsar from Apache Pulsar topic?
Consider the code for consuming messages from Apache Pulsar that is set up with spring-pulsar:
@PulsarListener(
subscriptionName = "hello-pulsar-sub-2",
topics = "#{...
0
votes
2
answers
252
views
Pulsar Consumer process delay in network connection reset
I have an issue in pulsar consumer
The subscription type is Key_Shared
The consumer consumed message, it has been disconnected from pulsar with network error and pod has been restarted and message has ...
0
votes
1
answer
102
views
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 ...
0
votes
2
answers
250
views
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: ...
0
votes
1
answer
531
views
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 ...
1
vote
1
answer
384
views
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(<T> message)
//...
I'm using ...
0
votes
1
answer
121
views
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 ...
0
votes
1
answer
84
views
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 as:
spring.pulsar.producer.cache.expire-after-access=...
3
votes
1
answer
2k
views
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:
<properties>
<java.version>20</java.version>
...
0
votes
0
answers
119
views
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 ...
3
votes
2
answers
389
views
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-...
0
votes
1
answer
803
views
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 ...
1
vote
2
answers
367
views
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 ...
1
vote
1
answer
906
views
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 ...
0
votes
1
answer
269
views
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 ...
2
votes
2
answers
561
views
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.
...