26 questions
Score of 1
1 answer
78 views
Spring Pulsar: Missing spring-pulsar-spring-cloud-stream-binder dependency
Problem
I'm setting up a Spring Boot application with Apache Pulsar integration using Spring Cloud Stream. When trying to build my project, I'm getting the following error:
auth-service:main: Could ...
Score of 1
0 answers
100 views
Kafka on Pulsar (KoP) has been archived. What are the good solutions to enable Pulsar to support the Kafka protocol in higher versions?
Kafka on Pulsar (KoP), which was a solution enabling Pulsar to support the Kafka protocol, has now been archived. This means that the active development and maintenance of KoP may have ceased. For ...
Score of 0
0 answers
144 views
Springboot + Spring Cloud Stream + Pulsar Binder startup failed
We want to use Pulsar binder to configure Pulsar consumer that produces on Kafka with usage of multibinder approach (https://docs.spring.io/spring-cloud-stream/reference/spring-cloud-stream/multiple-...
Score of 0
1 answer
259 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....
Score of 0
1 answer
266 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 ...
Score of 0
1 answer
68 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 ...
Score of 1
1 answer
187 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 @...
Score of 0
1 answer
93 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 ...
Score of 0
1 answer
66 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 ...
Score of 0
1 answer
100 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",
...
Score of 0
1 answer
177 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 = "#{...
Score of 0
2 answers
543 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 ...
Score of 0
1 answer
202 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 ...
Score of 1
2 answers
471 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: ...
Score of 0
1 answer
889 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 ...