26 questions
1
vote
1
answer
61
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 ...
- 137
1
vote
0
answers
93
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 ...
- 131
0
votes
0
answers
137
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-...
- 1
0
votes
1
answer
231
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....
- 53
0
votes
1
answer
254
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
67
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 ...
- 508
1
vote
1
answer
165
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 @...
- 508
0
votes
1
answer
88
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 ...
- 107
0
votes
1
answer
60
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 ...
- 1,198
0
votes
1
answer
89
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",
...
- 1,198
0
votes
1
answer
167
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 = "#{...
- 396
0
votes
2
answers
502
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
195
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 ...
1
vote
2
answers
459
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: ...
- 288
0
votes
1
answer
861
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 ...
- 33