Druid Mcp Server
Connects your AI assistant directly to Apache Druid clusters for analytics and cluster management through natural language. Exposes tools for querying datasources, managing ingestion tasks, monitoring cluster health, and killing segments or datasources. Built on Spring AI with support for stdio, SSE, and HTTP transports, plus OAuth2 security out of the box. The feature-based architecture auto-discovers tools via annotations, and you can run it in read-only mode to prevent modifications. Ships as a Docker container or standalone JAR, and pairs with iunera's Ypipe desktop app for a conversational UI. If you're running Druid and want to explore time series data or manage clusters through Claude or ChatGPT instead of the console, this gives you the MCP integration.
- GitHub stars
- 18
- tools
- 29
- auth
- Secret needed
- transport
- STDIO
- env vars
- 6
- last updated
- Aug 31, 2026
Tools
29 toolsPublic tool metadata for what this MCP can expose to an agent.
getDatasourcesList all available Apache Druid datasources or get detailed schema for a specific datasource.
List all available Apache Druid datasources or get detailed schema for a specific datasource.
No parameter schema in public metadata yet.
getLookupsGet configuration or status of lookups for all or a specific tier.
Get configuration or status of lookups for all or a specific tier.
No parameter schema in public metadata yet.
getSegmentsFetch segments metadata or details for a specific segment.
Fetch segments metadata or details for a specific segment.
No parameter schema in public metadata yet.
getSegmentLoadQueueGet the load queue status showing segments currently being loaded.
Get the load queue status showing segments currently being loaded.
No parameter schema in public metadata yet.
queryDruidSqlExecute a SQL query against Druid datasources.
Execute a SQL query against Druid datasources.
No parameter schema in public metadata yet.
getCompactionConfigView compaction configuration or configuration change history for datasources.
View compaction configuration or configuration change history for datasources.
No parameter schema in public metadata yet.
getCompactionStatusRetrieve the current status of compaction runs and progress.
Retrieve the current status of compaction runs and progress.
No parameter schema in public metadata yet.
manageCompactionAdd, update, or remove a compaction configuration.
Add, update, or remove a compaction configuration.
No parameter schema in public metadata yet.
manageDatasourceOrSegmentModify segment states or permanently drop a datasource.
Modify segment states or permanently drop a datasource.
No parameter schema in public metadata yet.
manageLookupCreate, update, or delete a lookup configuration.
Create, update, or delete a lookup configuration.
No parameter schema in public metadata yet.
queryDruidMultiStageExecute a multi-stage SQL query (MSQ) against Druid datasources as a task.
Execute a multi-stage SQL query (MSQ) against Druid datasources as a task.
No parameter schema in public metadata yet.
queryDruidMultiStageWithContextExecute a multi-stage SQL query with custom context parameters.
Execute a multi-stage SQL query with custom context parameters.
No parameter schema in public metadata yet.
getMultiStageQueryTaskStatusGet the status of a multi-stage query task.
Get the status of a multi-stage query task.
No parameter schema in public metadata yet.
cancelMultiStageQueryTaskCancel a running multi-stage query task.
Cancel a running multi-stage query task.
No parameter schema in public metadata yet.
getRetentionRulesRetrieve retention rules or audit history for a specific datasource or all datasources.
Retrieve retention rules or audit history for a specific datasource or all datasources.
No parameter schema in public metadata yet.
manageRetentionRulesUpdate retention rules configuration for a specific datasource.
Update retention rules configuration for a specific datasource.
No parameter schema in public metadata yet.
submitIngestionSubmit a Druid ingestion specification or generate a simple batch template.
Submit a Druid ingestion specification or generate a simple batch template.
No parameter schema in public metadata yet.
getSupervisorsList all supervisors or query details of a specific supervisor.
List all supervisors or query details of a specific supervisor.
No parameter schema in public metadata yet.
manageSupervisorSuspend, resume, or terminate a supervisor's execution.
Suspend, resume, or terminate a supervisor's execution.
No parameter schema in public metadata yet.
getTasksList ingestion tasks matching specific states.
List ingestion tasks matching specific states.
No parameter schema in public metadata yet.
getTaskDetailsFetch detailed information, specifications, execution reports, or execution logs for a task.
Fetch detailed information, specifications, execution reports, or execution logs for a task.
No parameter schema in public metadata yet.
shutdownTaskKill/shutdown a Druid task.
Kill/shutdown a Druid task.
No parameter schema in public metadata yet.
getClusterStatusCheck overall health or fetch specific metadata/properties from coordinators or routers.
Check overall health or fetch specific metadata/properties from coordinators or routers.
No parameter schema in public metadata yet.
getNodesStatusList registered servers, their detailed status, or single node status.
List registered servers, their detailed status, or single node status.
No parameter schema in public metadata yet.
diagnoseClusterPerform automated diagnostic health checks, configuration audits, or query performance analysis.
Perform automated diagnostic health checks, configuration audits, or query performance analysis.
No parameter schema in public metadata yet.
checkFunctionalityHealthValidate operations of ingestion systems, supervisor state transitions, and historical query latency.
Validate operations of ingestion systems, supervisor state transitions, and historical query latency.
No parameter schema in public metadata yet.
manageAuthenticationAdminister basic security users and credentials.
Administer basic security users and credentials.
No parameter schema in public metadata yet.
manageAuthorizationManage security authorization properties, roles, and resource access policies.
Manage security authorization properties, roles, and resource access policies.
No parameter schema in public metadata yet.
manageSecurityAssignmentsConfigure mapping rules assigning roles to users, or retrieve the configured authenticator chains.
Configure mapping rules assigning roles to users, or retrieve the configured authenticator chains.
No parameter schema in public metadata yet.
Sponsors
Agent CaffeineSponsoredClose your lid, come back to finished work
SnugSponsoredThe clipboard manager for the AI eraPromote your product hereReach 125k+ visitors monthly
WaxSponsoredBlock anything with supervision, without erasing your iPhonePromote your product hereReach 125k+ visitors monthly
knobsSponsoredSee your site on any phone, any day, in any languageConfiguration
DRUID_ROUTER_URL*Druid router URL for connecting to the Druid cluster
DRUID_COORDINATOR_URLDruid coordinator URL for querying metadata endpoints (optional)
DRUID_AUTH_USERNAMEUsername for Druid authentication (optional)
DRUID_AUTH_PASSWORDsecretPassword for Druid authentication (optional)
DRUID_SSL_ENABLEDEnable SSL/TLS support for Druid connections
DRUID_SSL_SKIP_VERIFICATIONSkip SSL certificate verification (for development/testing only)
Readme
Druid MCP Server
A comprehensive Model Context Protocol (MCP) server for Apache Druid that provides extensive tools, resources, and prompts for managing and analyzing Druid clusters.
Developed by iunera - Advanced AI and Data Analytics Solutions
Overview
This MCP server implements a intend-based architecture where profiles picture their usaae intend and the corresponding area of Druid usage. The server provides three main types of MCP components:
- Tools - Executable functions for performing operations
- Resources - Data providers for accessing information
- Prompts - AI-assisted guidance templates
Video Walkthrough
Learn how to integrate AI agents with Apache Druid using the MCP server. This tutorial demonstrates time series data exploration, statistical analysis, and data ingestion using natural language with AI assistants like Claude, ChatGPT, and Gemini.
Details
- Repository
- github.com/iunera/druid-mcp-server
- Package
docker.io/iunera/druid-mcp-server:2.0.1- Transport
- STDIO
- Auth
- Required
- Registry
- MCP registry, active