Does this entry from zookeeper get removed automatically after few seconds , till what time the entry will exist for the old pulsar-broker

in zookeeper

This message was deleted.

For a pulsar client, are there alternatives to tlsTrustCertsFilePath() ? For example if I would like to use an inputStream instead?

@Olav Groenaas Gjerde I think it's a good idea to ask in the channel for the specific client, you are using.

Its the Java client, Both PulsarAdmin.builder() And PulsarClient builder. For example if I want to read the tlsTrustCerts from Hashicorp Vault or Azure Key Vault.

Streaming and stream processing are a hot topic 🔥 Apache Flink gains more popularity by the day and for those interested I'm working on a hands-on book https://leanpub.com/streamprocessingwithapacheflink Although WIP the last chapter will be going over Flink and Pulsar as they play extremely well together and the pulsar-flink connector is quite sophisticated, providing a strong integration with a lot of functionality.

This message was deleted.

Hello, We would like to use pulsar as a buffer to process aggregations. In our case, we would like to maximize batch receive size instead of latency, ie: BatchReceivePolicy with a very long timeout and a high number of messages. I've read the client source code, and in my undestanding, the client is performing batching in memory (with incomingMessages blocking queue). Since my application will connect to a lot of topics (possibly 1-5k), I'm not comfortable with this. I'd like to prevent OOM when there is a lot of pending messages. Since pulsar broker knows how much messages are in backlog, is there a way to have a callback to notify client that it can consume this topic ? Thanks for your feedbacks

Hello! Tell me please. When will version 2.10.5 be released?

This message was deleted.

This message was deleted.

This message was deleted.

This message was deleted.

Hi all, I have been working on using E2EE in Pulsar. I have a standalone deployed in a docker container, and I created a Java Client with a consumer and producer. I have successfully created my private and public keys through openssl and am able to send and receive messages. Everything seems to be working but I want to verify that my messages are actually being encrypted. Is there a way I can verify this and how so? I haven't been able to find any logs showing it. Appreciate any help

@Amanda One way is to step through the consumer code using a debugger to view the message contents. You might also want to try consuming them using a client that is configured to use no/a different crypto key to decrypt the message and confirm that it fails.

In a cluster setup while restarting one broker all are going down at once. V: 2.11.0

Error connecting to broker: org.apache.pulsar.client.api.PulsarClientException$LookupException: {"errorMsg":"org.apache.pulsar.metadata.api.MetadataStoreException$NotFoundException:
ERROR org.apache.pulsar.client.impl.ClientCnx - [id: 0x23480539, L:/1ip:47740 - R:xx-pulsar-211-broker-2.xx-pulsar-211-broker.pulsar.svc.cluster.local/xx.xx.xx.xx:6650] Close connection because received internal-server error org.apache.pulsar.metadata.api.MetadataStoreException$NotFoundException: /loadbalance/brokers/xx-pulsar-211-broker-1.xx-pulsar-211-broker.pulsar.svc.cluster.local:8080

📣 The Apache Pulsar community meets every 2 weeks virtually. We discuss open Pull Requests, Proposals (PIP), future roadmaps, and chit-chatting on everything Pulsar. Join us! It’s today at 15:30 UTC. All details are here: https://github.com/apache/pulsar/wiki/Community-Meetings

This message was deleted.

Hi, I've got this exception :

org.apache.pulsar.client.api.PulsarClientException$TimeoutException: The producer myproducer-0 can not send message to the topic <persistent://public/default/mytopic> within given timeout : createdAt 11.369 seconds ago, firstSentAt 11.369 seconds ago, lastSentAt 11.369 seconds ago, retryCount 1

I don't understand the meaning of the 11.369s cause when I read the following doc https://pulsar.apache.org/api/client/3.0.x/org/apache/pulsar/client/api/ProducerBuilder.html#sendTimeout(int,java.util.concurrent.TimeUnit) I saw default value is 30s. Any idea to help me understand this strange behavior ?

This message was deleted.

This message was deleted.

This message was deleted.

This message was deleted.

Hi, I’m using Pulsar 3.0.0 deployed on EKSHow do I know the default values of the following env vars:

loadBalancerMsgRateDifferenceShedderThreshold

loadBalancerMsgThroughputMultiplierDifferenceShedderThreshold

when I exec into the pod and type env | grep

loadBalancerMsgThroughputMultiplierDifferenceShedderThreshold

I don’t see this env var any idea?

This message was deleted.

This message was deleted.

This message was deleted.

This message was deleted.