Stack Overflow
Stack Overflow

Questions tagged [python-pulsar]

Event driven concurrent framework for python.

With pulsar you can write asynchronous servers performing one or several activities in different threads and/or processes.

27 questions
3
votes
1 answer

Exception: Pulsar error: IncompatibleSchema

I am new to Pulsar and I am just exploring the functionalities for a new project. I am trying a very basic example to send data from a producer based on schema. To give some background, my idea is to send the data from apache-pulsar to Clickhouse…
Newbie_Python
  • 115
  • 7
3
votes
2 answers

pulsar-client couldn't be installed

I cannot install pulsar-client as it is mentioned in the documentation at all: pip3 install pulsar-client Collecting pulsar-client ERROR: Could not find a version that satisfies the requirement pulsar-client (from versions: none) ERROR: No…
Gurgen Hovhannisyan
  • 79
  • 6
2
votes
1 answer

How to work with protobuf schema messages in Python Apache pulsar pulsar-client package?

Is there a way to publish message to an Apache Pulsar topic using Protobuf schema using pulsar-client package using python? As per the documentation, it supports only Avro, String, Json and bytes. Any work around for…
Murthy Vissapragada
  • 23
  • 2
2
votes
1 answer

Publishing to Topic with registered schema in Apache Pulsar

As shown in the example in Pulsar Schema Registry Docs Producer producer = client.newProducer(JSONSchema.of(User.class)) .topic(topic) .create(); User user = new User(“Tom”, 28); producer.send(User); You can register schema for both…
Karlson
  • 2,958
  • 1
  • 21
  • 48
2
votes
1 answer

Pulsar: Error Checking/Getting Partition Metadata while Subscribing on persistent://public/default/test

I currently have a docker-compose.yml file which brings up a number of services. One of these services is pulsar, and another is a webserver which is connected to via websocket. When I bring up these services, the websocket container doesn't work.…
Jordan Gillard
  • 301
  • 1
  • 5
  • 14
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

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
1 answer

Does Python Pulsar-Client SDK supports pulsar admin based classes?

Hi I was looking to fetch metadata of pulsar topics using python-client sdk provided by pulsar. But i got stuck as , i was not able to find any classes regarding pulsar-admin actions like getting topics , there schema , stats etc. Though the same…
learn learn
  • 13
  • 2
1
vote
1 answer

How can I read all topic?

When I create the consumer consumer = pulsar.Client( PULSAR_URL, authentication=AuthenticationOauth2(params) ).subscribe( topic=PULSAR_TOPIC, subscription_name=PULSAR_SUBSCRIPTION_NAME …
Tlaloc-ES
  • 4,825
  • 7
  • 38
  • 84
1
vote
1 answer

error 404 when try to make oauth in pulsar stream native cluster

Hello I am triying to connect to apache pulsar cluster using stream native, I don't have problems with token oauth, but when I try to make Oauth I always get malformed responde or 404 I am using curl and python client, and following their…
Tlaloc-ES
  • 4,825
  • 7
  • 38
  • 84
1
vote
1 answer

Replay / Reset messages in Apache Pulsar

Is it possible to replay old messages (within retention period)? There is no documentation about it. I would like to do this based on a timestamp or period. A hint in the right direction would be much appreciated.
ielkhalloufi
  • 652
  • 1
  • 10
  • 27
1
vote
1 answer

Pulsar GoClient Equivalent of unacked_messages_timeout_ms (py-client)

In Pulsar Python Client, there is subscriber option unacked_messages_timeout_ms to set the interval after which the unacked messages will be redelivered. What is the equivalent of that in Pulsar Go Client ? Python py_consumer = client.subscribe( …
Shubham Jain
  • 876
  • 1
  • 9
  • 17
1
vote
1 answer

Apache Pulsar installation in Windows Docker

Could you please help me how to install a local standalone pulsar cluster using windows docker.i have followed the below options.but i couldn't able to access the pulsar UI 8080 port is already allocated for some other process.so here i'm using…
anbutech17
  • 29
  • 3
1
vote
1 answer

Create Key_Shared Consumer Apache Pulsar

I use the Apache Pulsar Python clients to connect my micro services. I want to create Key_Shared Consumer doing like: import pulsar,_pulsar client = pulsar.Client('pulsar://localhost:6650') consumer = client.subscribe('my-topic',…
Max0u
  • 691
  • 1
  • 9
  • 21
1
vote
0 answers

Function Exceptions in Pulsar (PUB-SUB)

I need help with Pulsar Function Exceptions, what are User Function Exceptions and what will happen if its Rate/Count is high and also what could be the cause of high Rate/Count.
basit khan
  • 81
  • 1
  • 7
1
2