Skip to content

pulsar_admin_subscriptions.md

Latest commit

 

History

History
42 lines (37 loc) · 2.33 KB

pulsar_admin_subscriptions.md

File metadata and controls

42 lines (37 loc) · 2.33 KB
Raw

pulsar_admin_subscription

Claude connector safety: Actual MCP tools: pulsar_admin_subscription_read (list, peek, get-message-by-id) and pulsar_admin_subscription_write (create, delete, skip, expire, reset-cursor).

Manage Pulsar topic subscriptions, which represent consumer groups reading from topics.

  • list: List all subscriptions for a topic
    • topic (string, required): The fully qualified topic name
  • create: Create a new subscription
    • topic (string, required): The fully qualified topic name
    • subscription (string, required): The subscription name
    • messageId (string, optional): Initial position, default is latest
  • delete: Delete a subscription
    • topic (string, required): The fully qualified topic name
    • subscription (string, required): The subscription name
    • force (boolean, optional): Force delete active consumers
  • skip: Skip messages for a subscription
    • topic (string, required): The fully qualified topic name
    • subscription (string, required): The subscription name
    • count (number, required): Number of messages to skip
  • expire: Expire messages for a subscription
    • topic (string, required): The fully qualified topic name
    • subscription (string, required): The subscription name
    • expireTimeInSeconds (number, required): Expiry time in seconds
  • reset-cursor: Reset subscription position
    • topic (string, required): The fully qualified topic name
    • subscription (string, required): The subscription name
    • messageId (string, required): Message ID to reset to
  • peek: Peek messages for a subscription without advancing the cursor
    • topic (string, required): The fully qualified topic name
    • subscription (string, required): The subscription name
    • count (number, optional): Number of messages to return, default is 1, maximum is 100
  • get-message-by-id: Read a message by ledger ID and entry ID
    • topic (string, required): The fully qualified topic name
    • ledgerId (number, required): Non-negative ledger ID of the message
    • entryId (number, required): Non-negative entry ID of the message

Message payloads returned by peek and get-message-by-id include:

  • payload: text view of the payload
  • payloadBase64: lossless base64 encoding of the raw bytes
  • payloadHex: hexadecimal dump for debugging