Skip to main content
Stack Overflow
  1. About
  3. For Teams
Filter by
Sorted by
Tagged with
1 vote
2 answers
97 views

I am having some issues to communicate with pulsar, I would like to have a producer that can connect from my host (machine) to the service in docker, but also allow a docker service to connect to it ...
David's user avatar
  • 146
0 votes
1 answer
60 views

I am currently building up an adapter for ioBroker, which should handle my wallbox via OCPP - usind ocpp-rpc library. I know, there are many OCPP backend systems out there, but they are not working as ...
Stef's user avatar
  • 13
0 votes
0 answers
37 views

I'm currently trying to move this code : Tuya SDK Java from Intelij Idea IDE to Android Studio. I did found the library on Android studio (adding in my build.gradle) implementation 'org.apache.pulsar:...
kaldoran's user avatar
  • 865
1 vote
1 answer
93 views

My ultimate goal is to find the number of partitions for a Pulsar topic (Getting number of partitions of a Pulsar topic: could not be parsed into a proper Uri, missing scheme) but in the process of an ...
0 votes
1 answer
100 views

I'm unable to get the number of partitions from a topic via the PulsarAdmin API: val admin: PulsarAdmin = PulsarAdmin .builder() ....
1 vote
0 answers
91 views

TLDR; How is void seek(Function<String,Object> function) throws PulsarClientException in the pulsar reader API expected to be used? -- More info I'd like to read messages from a pulsar topic ...
0 votes
1 answer
150 views

Debezium provides the filter single message transform (SMT). https://debezium.io/documentation/reference/stable/transformations/filtering.html#set-up-filter If I want to add the following ...
0 votes
1 answer
128 views

I changed the configuration in pulsar's configuration file broker.conf to brokerDeleteInactiveTopicsEnabled: true brokerDeleteInactiveTopicsMode: delete_when_no_subscriptions ...
1 vote
0 answers
169 views

I have simple pulsar consumer pulsar_client.subscribe( topic=re.compile('persistent://public/default/some_topic_[a-zA-Z0-9_\-]+1$'), subscription_name=consumer_group, consumer_type=ConsumerType....
0 votes
1 answer
210 views

I am reading messages continuously. I want to close my client and consumer if no message is there to read. The below code is working fine if there are messages to read but after reading all the ...
0 votes
1 answer
227 views

I want to know the number of messages in a pulsar partitioned topic that isn't picked up by any of the consumers yet. My application is in python so I am using the REST APIs. I tried both /admin/v2/...
VVictor's user avatar
  • 269
0 votes
1 answer
194 views

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 ...
2 votes
1 answer
116 views

I'm trying to deploy and configure DataStax Apache Pulsar JMS Client Resource Adapter in JBoss but I'm getting the following error: 2023年08月28日 11:21:30,684 INFO [org.jboss.weld.deployer] (MSC service ...
MLeiria's user avatar
  • 623
0 votes
0 answers
275 views

When using Apache Flink SQL connector for Pulsar (link), I consistently get the Avro deserialization problem when trying to read from a Flink table that is backed by a Pulsar topic (having an Avro ...
1 vote
2 answers
457 views

Let's say I have the following pulsar config: pulsar: topicX: client: config: numIoThreads: 3 numListenerThreads: 15 consumer: config: receiverQueueSize: ...

15 30 50 per page
1
2 3 4 5

AltStyle によって変換されたページ (->オリジナル) /