Pulsar MCP Server
Server Configuration
Describes the environment variables required to run the server.
| Name | Required | Description | Default |
|---|---|---|---|
| TOPIC_NAME | No | Default topic name | |
| PULSAR_TOKEN | No | JWT token for authentication | |
| SUBSCRIPTION_NAME | No | Default subscription name | pulsar-mcp-subscription |
| SUBSCRIPTION_TYPE | No | Subscription type (Exclusive, Shared, Failover, Key_Shared) | Shared |
| PULSAR_SERVICE_URL | No | Pulsar broker service URL | pulsar://localhost:6650 |
| PULSAR_WEB_SERVICE_URL | No | Pulsar web service URL | http://localhost:8080 |
| IS_TOPIC_READ_FROM_BEGINNING | No | Whether to read from beginning | false |
| PULSAR_TLS_TRUST_CERTS_FILE_PATH | No | Path to TLS trust certificates file | |
| PULSAR_TLS_ALLOW_INSECURE_CONNECTION | No | Allow insecure TLS connection | false |
Capabilities
Features and capabilities supported by this server
| Capability | Details |
|---|---|
| tools | {
"listChanged": false
} |
| experimental | {} |
Tools
Functions exposed to the LLM to take actions
| Name | Description |
|---|---|
| pulsar_publishB | Publish a message to a Pulsar topic |
| pulsar_consumeB | Consume messages from a Pulsar topic |
| pulsar_create_topicC | Create a new Pulsar topic |
| pulsar_delete_topicB | Delete an existing Pulsar topic |
| pulsar_list_topicsB | List all topics in the Pulsar cluster |
| pulsar_topic_statsB | Get statistics and metadata about a topic |
| pulsar_list_connectorsA | List all connectors of specified type (source or sink) |
| pulsar_connector_statusB | Get the status of a specific connector |
| pulsar_connector_configB | Get the configuration of a specific connector |
| pulsar_all_connectorsB | Get all connectors organized by type (source and sink) |
Prompts
Interactive templates invoked by user choice
| Name | Description |
|---|---|
No prompts | |
Resources
Contextual data attached and managed by the client
| Name | Description |
|---|---|
No resources | |
Latest Blog Posts
- Your AI Chatbot Just Exposed Your CEO's Salary to an InternBy Om-Shree-0709 on .Agent IdentityMCP SecurityOAuth Delegation
- Why MCP Servers Need Execution Sandboxing (And Why Your Current Stack Isn't Enough)By Om-Shree-0709 on .Agentic AiPrompt InjectionWebAssembly
MCP directory API
We provide all the information about MCP servers via our MCP API.
curl -X GET 'https://glama.ai/api/mcp/v1/servers/Germain-D/pulsar-mcp-server'
If you have feedback or need assistance with the MCP directory API, please join our Discord server