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 |
Instructions
Guidance the server publishes about itself, which clients place ahead of the tool catalog so the model reads it before choosing anything.
This server publishes no instructions, or was last inspected before Glama recorded them.
Capabilities
Features and capabilities supported by this server
Protocol revision2025-11-25
| 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 | |
TDQS
Scored across 82 tools
Many tools have overlapping purposes, such as multiple 'get_connector' variations and several job/stream/table retrieval tools, making it difficult for an agent to distinguish between them without careful reading.
Most tools follow a consistent verb_noun pattern (e.g., get_, list_, create_, delete_), though there are minor inconsistencies like 'register_kafka_table' vs 'create_kafka_table' and some verbs are used interchangeably.
With 82 tools, the surface is excessively large for a single server, which overwhelms agents and increases the chance of misselection; a more focused set would be better.
The tool set covers a wide range of SSB operations, including lifecycle management for projects, environments, streams, jobs, tables, connectors, and UDFs, though a few minor operations might be missing.