https://pulsar.apache.org/ logo
Join Slack
Powered by
# ask-ai
  • s

    Suhas Karanth

    06/25/2025, 7:24 AM
    @RunLLM we are planning to use Apache Pulsar as a replacement for Google Pub/Sub. We are only using Shared or Key_Shared subscription types. The total number of topics in the cluster will not exceed 100 and we are planning to use a single tenant and namespace for all of them. What are the metrics that we should set an alert on for monitoring Apache Pulsar?
    r
    • 2
    • 1
  • s

    Suhas Karanth

    06/25/2025, 7:40 AM
    @RunLLM what is
    max_total_receiver_queue_size_across_partitions
    ?
    r
    • 2
    • 1
  • s

    Suhas Karanth

    06/26/2025, 3:52 AM
    @RunLLM does the receiver queue size include messages that are in the middle of being processed or have been NACKed?
    r
    • 2
    • 3
  • s

    Suhas Karanth

    06/26/2025, 8:20 AM
    @RunLLM can you help me understand
    journalSyncData
    configuration option for Bookkeeper? How do I decide if it should be
    true
    or
    false
    ?
    r
    • 2
    • 11
  • t

    Thomas MacKenzie

    06/26/2025, 6:13 PM
    @RunLLM Can you help me understand the
    loadBalancerLoadPlacementStrategy
    configuration option on the broker and what the different values are?
    r
    • 2
    • 4
  • t

    Thomas MacKenzie

    06/26/2025, 7:22 PM
    @RunLLM Can you explain the configuration option
    publishNotReadyAddresses
    on bookkeeper?
    r
    l
    • 3
    • 5
  • t

    Thomas MacKenzie

    06/26/2025, 9:49 PM
    @RunLLM What are the possible values for the configuration option
    loadBalancerLoadSheddingStrategy
    on the broker?
    r
    • 2
    • 17
  • s

    Suhas Karanth

    06/27/2025, 3:51 AM
    @RunLLM if I use batching without index acknowledgement, is it possible to use redelivery for a specific message? Or will all the messages in the batch be redelivered?
    r
    • 2
    • 3
  • s

    Suhas Karanth

    06/27/2025, 5:34 AM
    @RunLLM what is the relevance of
    allowAutoSubscriptionCreation
    configuration option?
    r
    • 2
    • 1
  • s

    Stanislaw Makarawec

    06/27/2025, 3:31 PM
    @RunLLM I've set
    subscriptionExpirationTimeMinutes
    in broker.conf but unactive subscriptions wasn't deleted. Pulsar 4.0.4. What should I do, for auto cleanup subscriptions without active consumers?
    r
    • 2
    • 15
  • t

    Thomas MacKenzie

    06/28/2025, 4:45 AM
    @RunLLM is
    preciseTopicPublishRateLimiterEnable
    a configuration option on the broker?
    r
    l
    • 3
    • 13
  • s

    Suhas Karanth

    06/30/2025, 7:24 AM
    @RunLLM if I want to run Pulsar on arm64 architecture, where can I find the binaries for it?
    r
    l
    • 3
    • 4
  • s

    sindhushree

    07/02/2025, 5:58 AM
    @RunLLM On one of the cluster the org.apache.pulsar.client.impl.ProducerStatsRecorderImpl shows high latency Latency: med: 7002.000 ms - 95pct: 10907.000 ms - 99pct: 10996.000 ms - 99.9pct: 11020.000 ms - max: 11163.000 ms
    r
    • 2
    • 14
  • s

    sindhushree

    07/08/2025, 1:52 AM
    @RunLLM namespace unload or rebalance is not balancing brokers .
    r
    • 2
    • 7
  • s

    sindhushree

    07/08/2025, 5:33 AM
    @RunLLM producer stats show high latency as 3000 ms however the pulsar_storage_write_latency is less than 5ms this shows broker is taking time what could be the reason ?
    r
    • 2
    • 25
  • m

    Mustaque

    07/08/2025, 5:57 AM
    @RunLLM pls help with error
    Copy code
    --- An unexpected error occurred in the server --- Message: org.apache.bookkeeper.mledger.ManagedLedgerException: Not enough non-faulty bookies available error code: -6 Stacktrace: org.apache.pulsar.broker.service.BrokerServiceException$PersistenceException: org.apache.bookkeeper.mledger.ManagedLedgerException: Not enough non-faulty bookies available error code: -6 at org.apache.pulsar.broker.service.BrokerService$2.openLedgerFailed(BrokerService.java:1899) at org.apache.bookkeeper.mledger.impl.ManagedLedgerFactoryImpl.lambda$asyncOpen$10(ManagedLedgerFactoryImpl.java:466) at java.base/java.util.concurrent.CompletableFuture.uniExceptionally(Unknown Source) at java.base/java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(Unknown Source) at java.base/java.util.concurrent.CompletableFuture.postComplete(Unknown Source) at java.base/java.util.concurrent.CompletableFuture.completeExceptionally(Unknown Source) at org.apache.bookkeeper.mledger.impl.ManagedLedgerFactoryImpl$2.initializeFailed(ManagedLedgerFactoryImpl.java:457) at org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl.lambda$initializeBookKeeper$2(ManagedLedgerImpl.java:583) at org.apache.bookkeeper.common.util.SingleThreadExecutor.safeRunTask(SingleThreadExecutor.java:137) at org.apache.bookkeeper.common.util.SingleThreadExecutor.run(SingleThreadExecutor.java:107) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Unknown Source) Caused by: org.apache.bookkeeper.mledger.ManagedLedgerException: Not enough non-faulty bookies available error code: -6
    r
    p
    • 3
    • 4
  • v

    Viji

    07/09/2025, 5:49 AM
    @RunLLM, what is the recommended option to rollback after pulsar upgrade on a K8s deployment ?
    r
    • 2
    • 1
  • j

    Joshua

    07/09/2025, 9:59 AM
    @RunLLM Is it possible to get the enqueued timestamp of the last message in a topic via the Pulsar Admin API through a single or mutiple chained admin API calls?
    r
    • 2
    • 3
  • s

    Stanislaw Makarawec

    07/11/2025, 10:59 AM
    @RunLLM we have problem with deleteting tenant. When deleting topics step by step, i get error, topic already offloaded. Reapeting doesn't help. How to avoid it?
    r
    • 2
    • 9
  • s

    Suhas Karanth

    07/14/2025, 5:06 AM
    @RunLLM How can I specify the hashing scheme with the Python library for Pulsar?
    r
    • 2
    • 1
  • s

    sindhushree

    07/14/2025, 7:28 AM
    @RunLLM best way to monitor the pulsar interl health like ledger metadata and ledger corruptions
    r
    • 2
    • 7
  • s

    sindhushree

    07/16/2025, 3:52 AM
    @RunLLM How can i understand the details of znodes in zookeeper for a given topic
    r
    • 2
    • 5
  • s

    Suhas Karanth

    07/21/2025, 7:19 AM
    @RunLLM will metrics related to partitioned topics always be emitted at the level of each partition? Is it possible to instead get metrics at the topic level instead of partitioned topic?
    r
    • 2
    • 3
  • s

    Suhas Karanth

    07/21/2025, 7:27 AM
    @RunLLM which metric can be used to identify the oldest unacknowledged message in a topic?
    r
    • 2
    • 1
  • s

    sindhushree

    07/21/2025, 12:20 PM
    @RunLLM pulsar.dedup subscription is not moving
    r
    • 2
    • 16
  • i

    Ilya Brin

    07/21/2025, 7:02 PM
    @RunLLM it appears the recommendation when using the Java pulsar client is to not create a new producer for each message send, but rather to keep them around in some sort of map/LRU cache. Are there any existing tools/libraries/utilities that help achieve this, or any further information/recommendations?
    r
    • 2
    • 3
  • i

    Ilya Brin

    07/21/2025, 9:06 PM
    @RunLLM when i publish a message to pulsar using the Java library, i get an exception logged to the console:
    Copy code
    c.s.circe.checksum.Java9IntHash -- Unable to use reflected methods:
    java.lang.reflect.InaccessibleObjectException: Unable to make private static int java.util.zip.CRC32C.updateBytes(int,byte[],int,int) accessible: module java.base does not "opens java.util.zip" to unnamed module
    what causes it and how do i resolve it? i can provide the full stack trace if it helps
    r
    • 2
    • 3
  • s

    sindhushree

    07/22/2025, 5:23 AM
    @RunLLM Last ack timestamp is 0 for readers ?
    r
    • 2
    • 10
  • s

    sindhushree

    07/24/2025, 4:41 AM
    @RunLLM what does the isoffloaded means in the info-internal
    r
    • 2
    • 1
  • s

    Suhas Karanth

    07/25/2025, 10:53 AM
    @RunLLM for partitioned topics, if I want to clear the backlog, do I need to run the
    pulsar-admin topics clear-backlog
    command for each partitioned topic?
    r
    • 2
    • 1