| Tool | Mode | Operations |
|---|---|---|
pulsar_admin_topic_read |
read | list, get, get-permissions, stats, lookup, internal-stats, internal-info, bundle-range, last-message-id, compact-status, offload-status |
pulsar_admin_topic_write |
write | grant-permissions, revoke-permissions, create, delete, unload, terminate, compact, update, offload |
Claude connector safety: Actual MCP tools are split into pulsar_admin_topic_read and pulsar_admin_topic_write. The read tool is read-only and only exposes read operations/parameters. The write tool is destructive and is not registered in read-only mode.
Read topic metadata, permissions, statistics, lookup details, and long-running operation status.
-
topics
- list: List topics in a namespace
namespace(string, required): Namespace name intenant/namespaceformat
- list: List topics in a namespace
-
topic
- get: Get topic metadata
topic(string, required): Fully qualified topic name
- get-permissions: Get topic permissions for all roles
topic(string, required): Fully qualified topic name
- stats: Get topic statistics
topic(string, required): Fully qualified topic namepartitioned(boolean, optional): Treat topic as partitionedper-partition(boolean, optional): Include per-partition stats
- lookup: Look up the broker serving a topic
topic(string, required): Fully qualified topic name
- internal-stats: Get topic internal stats
topic(string, required): Fully qualified topic name
- internal-info: Get topic internal info
topic(string, required): Fully qualified topic name
- bundle-range: Get topic bundle range
topic(string, required): Fully qualified topic name
- last-message-id: Get the last message ID of a topic
topic(string, required): Fully qualified topic name
- compact-status: Get topic compaction status (
statusis accepted as a legacy alias)topic(string, required): Fully qualified topic namewait(boolean, optional): Poll until compaction status is final
- offload-status: Get topic offload status
topic(string, required): Fully qualified topic namewait(boolean, optional): Poll until offload status is final
- get: Get topic metadata
Manage topic lifecycle, permissions, partitioning, compaction, and offload state.
- topic
- grant-permissions: Grant topic permissions to a role
topic(string, required): Fully qualified topic namerole(string, required): Role to grant permissions toactions(array, required): Allowed values includeproduce,consume,sources,sinks,functions,packages
- revoke-permissions: Revoke all topic permissions from a role
topic(string, required): Fully qualified topic namerole(string, required): Role to revoke permissions from
- create: Create a topic
topic(string, required): Fully qualified topic namepartitions(number, required): Number of partitions; use0for non-partitioned
- delete: Delete a topic
topic(string, required): Fully qualified topic nameforce(boolean, optional): Force operation even if producers or consumers are activenon-partitioned(boolean, optional): Delete only a non-partitioned topic with this name
- unload: Unload a topic from broker memory
topic(string, required): Fully qualified topic name
- terminate: Terminate a topic
topic(string, required): Fully qualified topic name
- compact: Trigger topic compaction
topic(string, required): Fully qualified topic name
- update: Update topic partitions or configuration
topic(string, required): Fully qualified topic namepartitions(number, optional): New partition countconfig(string, optional): JSON topic configuration
- offload: Offload topic data to long-term storage
topic(string, required): Fully qualified topic namemessageId(string, required): Message ID up to which data should be offloaded
- grant-permissions: Grant topic permissions to a role