@RunLLM postgres sink with JsonSchema

@RunLLM How does

dispatchThrottlingOnBatchMessageEnabled

work?

@RunLLM Does subscription replication work with partitioned topics?

@RunLLM I want to use Pulsar Functions to consume a partitioned topic in Key_Shared mode. Does Pulsar Function support (micro)batch read from a topic?

@RunLLM from what version pulsar client no longer falling back to support non PIP-344 broker

@RunLLM from what version pulsar client no longer falling back to support non PIP-344 broker

@RunLLM Can transactions be used without the transaction coordinator initialized?

@RunLLM I am having a problem with topic replication. The topic replicates at about 10 messages per second, then for 2 minutes there is a sharp increase to 5k per second. Somewhere in the middle of the interval, replication to the remote cluster stops and does not resume. What should I do?

@RunLLM When is a subscription reset? I'm trying to understand the description in a Git issue that says

When resetting a subscription

@RunLLM Is it possible to enableStateStore for functions in StreamNative's serverless cluster?

@RunLLM Is there a way to delete or acknowledge a specific message by its in a topic without moving the subscription cursor?

@RunLLM The message id is a tuple like (754763,11,0,-1). What are the meanings of each position?

@RunLLM What is the latest Java Runtime that is working with Pulsar, Java 21 or Java 25?

@RunLLM what are the best recommendations to avoid race condition, for ledger creation by broker, a,k.a split brain personality

@RunLLM What are permits for and how are they used?

@RunLLM What is the combination for producer parameter to be used for blockifqueue full and producer exception for the backlog quota

Hi, could you please let me know when the new release candidates are expected to be officially released?

@RunLLM Is receive queue size is based on number of messages or size of the messeges.

@RunLLM How can I set JSON as the log format in Pulsar

4.0.9

?

@RunLLM How does the broker configuration field

topicFencingTimeoutSeconds

work?

@RunLLM [BookKeeperClientWorker-OrderedExecutor-0-0] WARN org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl - Failed to find 2 bookies : excludeBookies [], allBookies []. 2026-02-25T045409,503 [BookKeeperClientWorker-OrderedExecutor-0-0] ERROR org.apache.bookkeeper.client.LedgerCreateOp - Not enough bookies to create ledger with ensembleSize=2, writeQuorumSize=2 and ackQuorumSize=2

@RunLLM get stats require the super user role ?

@RunLLM is

managedLedgerMaxEntriesPerLedger

with a 5000 value considered too small?

@RunLLM Java 21 is the recommended JDK version since

branch-4.0 is it true?

@RunLLM namesapce unload

@RunLLM How can I set

pulsar-recovery

to format logs with JSON?

@RunLLM How to setup clients authentication using helm chart (oidc)?

@RunLLM Failed to find 2 bookies : excludeBookies [<Bookieitomdipulsar bookkeeper 0.itomdipulsar bookkeeper3181>, <Bookieitomdipulsar bookkeeper 2.itomdipulsar bookkeeper3181>, <Bookieitomdipulsar bookkeeper 1.itomdipulsar bookkeepe3181>, <Bookieitomdipulsar bookkeeper 3.itomdipulsar bookkeeper.3181>], allBookies [<Bookieitomdipulsar bookkeeper 0.itomdipulsar bookkeeper.3181>, <Bookie:itomdipulsar-bookkeeper-1.itomdipulsar-bookkeeper.3181>, <Bookieitomdipulsar bookkeeper 3.itomdipulsar bookkeeper.3181>, <Bookieitomdipulsar bookkeeper 2.itomdipulsar bookkeeper3181>] both exclude bookie and all bookie are same ..why this error ?

The AI agent @RunLLM doesn't seem to be connected to this topic anymore. One way to get good AI answers about Pulsar is to use Deepwiki MCP with Claude Desktop / Claude Code or other vendor's tool. Then you can ask with a prompt such as "Check apache/pulsar and apache/pulsar-site with Deepwiki MCP to find an answer to this question:"