Skip to main content
Filter by
Sorted by
Tagged with
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....
J. Hu's user avatar
  • 53
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 ...
user3120289's user avatar
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 ...
Gootik's user avatar
  • 510
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 @...
Gootik's user avatar
  • 510
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 ...
Suzy's user avatar
  • 87
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 ...
menapole's user avatar
  • 1,178
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", ...
menapole's user avatar
  • 1,178
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 = "#{...
Konrad's user avatar
  • 357
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 ...
Saeed Shahsavan's user avatar
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 ...
Sathiskumar Perumal's user avatar
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: ...
Thomas Verhoeven's user avatar
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 ...
Neha P's user avatar
  • 31
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 ...
Dan's user avatar
  • 55
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 ...
axiopisty's user avatar
  • 5,117
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=...
DeveloperV's user avatar
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> ...
silentsudo's user avatar
  • 6,965
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 ...
Noor Khan's user avatar
  • 160
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-...
user10200598's user avatar
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 ...
Hyungin Cho's user avatar
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 ...
Jeff's user avatar
  • 111
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 ...
Marcus Hellberg's user avatar
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 ...
Gootik's user avatar
  • 510
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. ...
Keshavram Kuduwa's user avatar