SSB MCP Server
Server Configuration
Describes the environment variables required to run the server.
| Name | Required | Description | Default |
|---|---|---|---|
| SSB_USER | No | SSB username (e.g., admin) - for direct SSB authentication | |
| KNOX_USER | No | Knox username for basic auth - for Knox authentication | |
| KNOX_TOKEN | No | Knox JWT token for authentication - for Knox authentication | |
| KNOX_COOKIE | No | Alternative: provide full cookie string instead of token - for Knox authentication | |
| SSB_API_BASE | No | Full SSB API URL (e.g., http://localhost:18121 or https://ssb-gateway.yourshere.cloudera.site/ssb/api/v1) | |
| SSB_PASSWORD | No | SSB password (e.g., admin) - for direct SSB authentication | |
| SSB_READONLY | No | Read-only mode (default: true for CDP deployments, false for standalone) | true |
| KNOX_PASSWORD | No | Knox password for basic auth - for Knox authentication | |
| KNOX_CA_BUNDLE | No | Path to CA certificate bundle | |
| KNOX_VERIFY_SSL | No | Verify SSL certificates | true |
| TIMEOUT_SECONDS | No | HTTP timeout in seconds | 30 |
| KNOX_GATEWAY_URL | No | Knox gateway URL (e.g., https://host:8444/gateway/ssb) - for Knox authentication | |
| KNOX_PASSCODE_TOKEN | No | Alternative: Knox passcode token (auto-exchanged for JWT) - for Knox authentication |
Capabilities
Features and capabilities supported by this server
| Capability | Details |
|---|---|
| tools | {
"listChanged": false
} |
| prompts | {
"listChanged": false
} |
| resources | {
"subscribe": false,
"listChanged": false
} |
| experimental | {} |
Tools
Functions exposed to the LLM to take actions
| Name | Description |
|---|---|
| get_ssb_infoA | Get SSB version and system information. |
| list_streamsA | List all SQL streams in SSB. |
| get_streamB | Get details of a specific SQL stream. |
| get_stream_statusB | Get the status of a SQL stream (running, stopped, etc.). |
| get_stream_metricsB | Get performance metrics for a SQL stream. |
| list_tablesA | List all available tables in SSB. |
| get_table_schemaB | Get schema information for a specific table. |
| execute_queryC | Execute a SQL query against SSB. |
| list_udfsA | List all available user-defined functions. |
| get_udfC | Get details of a specific user-defined function. |
| list_connectorsB | List all available connectors. |
| get_connectorC | Get details of a specific connector. |
| list_topicsB | List all Kafka topics. |
| get_topicC | Get details of a specific Kafka topic. |
| get_cluster_infoB | Get SSB cluster information. |
| get_cluster_healthB | Get SSB cluster health status. |
| get_job_statusA | Get status of a specific SSB job. |
| get_job_sampleC | Get sample data from a job execution. |
| get_job_sample_by_idC | Get sample data from a job by job ID. |
| list_jobs_with_samplesA | List all jobs with their sample information. |
| stop_jobC | Stop a specific SSB job. |
| execute_jobC | Execute/restart a specific SSB job with new SQL. |
| configure_samplingC | Configure sampling parameters for a job. |
| execute_query_with_samplingC | Execute a SQL query with proper sampling configuration. |
| restart_job_with_samplingC | Restart a job with new SQL and proper sampling configuration. |
| create_kafka_tableC | Create a new table that only uses local-kafka connector. |
| validate_kafka_connectorC | Validate that a connector type is the local-kafka connector and get its properties. |
| register_kafka_tableC | Register a Kafka table in the Flink catalog using DDL (makes it queryable). |
| create_streamC | Create a new SQL stream. |
| update_streamC | Update an existing SQL stream. |
| delete_streamC | Delete a SQL stream. |
| start_streamC | Start a SQL stream. |
| stop_streamC | Stop a SQL stream. |
| get_job_eventsC | Get detailed job event history and timeline. |
| get_job_stateC | Get comprehensive job state information. |
| get_job_mv_endpointsC | Get materialized view endpoints for a job. |
| create_job_mv_endpointC | Create or update a materialized view endpoint for a job. |
| copy_jobC | Duplicate an existing job. |
| copy_data_sourceC | Clone a data source. |
| get_diagnostic_countersB | Get system performance counters and diagnostics. |
| get_heartbeatA | Check system health and connectivity. |
| analyze_sqlA | Analyze SQL query without execution (syntax, performance analysis). |
| list_tables_detailedC | Get comprehensive table information. |
| get_table_treeA | Get hierarchical table structure organized by catalog. |
| validate_data_sourceC | Validate data source configuration. |
| create_table_detailedC | Create table with full configuration. |
| get_table_detailsC | Get detailed information about a specific table. |
| list_data_formatsB | List all available data formats. |
| get_data_format_detailsA | Get detailed information about a specific data format. |
| create_data_formatC | Create a new data format. |
| get_connector_jarC | Get connector JAR information. |
| get_connector_type_detailsC | Get detailed connector type information. |
| get_connector_detailsC | Get detailed connector information. |
| get_user_settingsA | Get user preferences and settings. |
| update_user_settingsC | Update user configuration. |
| list_projectsB | List available projects. |
| get_project_detailsC | Get project information. |
| create_projectC | Create a new project. |
| get_user_infoB | Get current user information. |
| list_api_keysB | List user API keys. |
| create_api_keyC | Create new API key. |
| delete_api_keyD | Delete API key. |
| get_api_key_detailsC | Get API key information. |
| list_environmentsB | List available environments. |
| activate_environmentC | Activate/switch to an environment. |
| get_environment_detailsC | Get environment configuration. |
| create_environmentC | Create new environment. |
| deactivate_environmentB | Deactivate current environment. |
| get_sync_configC | Get sync configuration. |
| update_sync_configC | Update sync configuration. |
| delete_sync_configB | Delete sync configuration. |
| validate_sync_configC | Validate sync configuration for a project. |
| export_projectC | Export project configuration. |
| import_projectD | Import project configuration. |
| list_udfs_detailedB | Get comprehensive UDF information. |
| run_udfC | Execute UDF function. |
| get_udf_artifactsB | Get UDF artifacts and dependencies. |
| create_udfD | Create custom UDF. |
| update_udfC | Update UDF configuration. |
| get_udf_detailsC | Get detailed UDF information. |
| get_udf_artifact_detailsC | Get UDF artifact details. |
| get_udf_artifact_by_typeC | Get UDF artifacts by type. |
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
- Who's Calling? MCP Hosts Are an Identity Blind Spot (And the Spec Knows It)By Om-Shree-0709 on .mcpAgent IdentityOAuth 2.1
- 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/BrooksIan/SSB-MCP-Server'
If you have feedback or need assistance with the MCP directory API, please join our Discord server