Stack Overflow
Stack Overflow

Questions tagged [pulsar]

Lightweight threads, CSP and Erlang-like actors for Clojure.

Pulsar is a Clojure library that provides high-performance lightweight threads and Erlang-like actors. It is a Clojure API for the Quasar Java library, with the addition of pattern matching and an Erlang-like syntax.

For more information: http://docs.paralleluniverse.co/pulsar/

67 questions
5
votes
0 answers

How to configure logging to file for Apache Pulsar in standalone mode?

I want to configure Apache Pulsar to log output to file when in standalone mode. I am running Pulsar in standalone mode from a systemd service, with an exec command like this: /var/lib/apache-pulsar/bin/pulsar standalone Now the Pulsar log…
lars
  • 640
  • 4
  • 10
4
votes
0 answers

Apache pulsar 2.8.0 standalone failing

Pulsar standalone do not start and i get such error. Maybe someone knows how to fix it? What I noticed, it happens when i turn off my pc and turn it on after night and try to start pulsar standalone. Also I have set retention for one of my…
MindaugasR
  • 41
  • 3
3
votes
1 answer

Excluding consumer of a topic by sender in Pulsar

Intro We're developing a system to support multiple real-time messages (chat) and updates (activity notifications). That is, user A can receive via Web Socket messages for : receiving new chat messages receiving updates for some activity, for…
BVtp
  • 2,308
  • 2
  • 29
  • 68
3
votes
2 answers

Retrieving all past messages from a apache pulsar topic

I think a simple example would describe my question better. For example, let's say there is a topic named "A" and I have produced 100 messages(message1...message100). I have already consumed and acknowledged up to message 50 using subscription "A_1"…
pandawithcat
  • 571
  • 2
  • 13
3
votes
1 answer

Is there a way to check if there exists a Pulsar producer with the same name on the same topic?

Pulsar allows multiple producers to subscribe to the same topic only if they have different producer names. Is there a way to check if a producer with the same name (and same topic) already exists?
doctopus
  • 5,349
  • 8
  • 53
  • 105
3
votes
1 answer

Clojure equivalent of "Actors"

I've been looking into Elixir and Akka recently, and that got me thinking: what's the equivalent in Clojure? I found a couple of "message throughput comparison" posts about agents vs actors, but they were from 8 years ago One answer used to be…
agam
  • 5,064
  • 6
  • 31
  • 37
2
votes
0 answers

Is there any Pulsar UI where messages can be updated/produced?

The only UI I found was Pulsar Manager , which don't even allow to see the messages in a topic. By any chance is there a Pulsar UI with better features where messages can be manipulated?
Sagar Panwar
  • 31
  • 2
2
votes
1 answer

How to correctly import a Maven dependency that I altered and re-built into an existing project?

I have a Maven dependency, pulsar-log4j2-appender, which I forked and changed the source code because it was throwing exceptions in my project. After changing the source code, I ran the maven package command to build the jar and imported it into my…
doctopus
  • 5,349
  • 8
  • 53
  • 105
2
votes
1 answer

Apache Pulsar disk usage in a container

I am running Apache pulsar in a Docker container in standalone mode. I am publishing log file lines into the pulsar topic. The total logs are about 60G in size. The pulsar container keeps running out of disk space on the / disk and has to…
punekr12
  • 653
  • 2
  • 7
  • 14
1
vote
1 answer

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( message) //... I'm using Intellij 2023.1 (Community edition) The full class code…
Dan
  • 45
  • 4
1
vote
0 answers

Pulsar does a infinite redelivery of message when maxredelivery count is breached for DLQ

I have simple setup where in i have pulasr consumer subscribing to a topic with DLQ of maxredelivery count= 2 on shared subscription type. So when the message is consumed we send the message via websocket to get a ack, but since the message is to…
Sanjay
  • 11
  • 3
1
vote
1 answer

Pulsar producer send_async() with callback function acknowledging the sent message

I have a use case where messages from an input_topic gets consumed and sent to a list of topics. I'm using producers[i].send_async(msg, callback=callback) where callback = lambda res, msg: consumer.acknowledge(msg). In this case, consumer is…
user3863316
  • 13
  • 3
1
vote
1 answer

How to run Push-Queries with Apache Pulsar?

I love the push queries (called continuous queries in Apache Flink) of Apache ksqlDB. https://developer.confluent.io/learn-kafka/ksqldb/push-queries-and-pull-queries/ It allows to get notified via HTTP2 of a new result of a query whenever the result…
feder
  • 1,849
  • 2
  • 25
  • 43
1
vote
1 answer

Make sure messages goes to a specific consumer

I have multiple consumers subscribed to the same Pulsar topic. How do I make sure certain messages go to specific consumers? The closest thing I understand is the key-shared consumer type. However, they seem to group the messages by a hash-range and…
Kevin Z.
  • 13
  • 3
1
vote
0 answers

pulsar-admin sink localrun failure: ClientCnx Failed to authenticate the client. (tls auth enabled)

command: bin/pulsar-admin sinks localrun -a connectors/pulsar-io-mongo-2.10.2.nar --tenant public --namespace default --inputs up-20wt --name mongo-sink --sink-config-file work/config.json --parallelism 1 log: 2023-01-06T14:56:27,441+0800…
blue
  • 11
  • 2
1
2 3 4 5