Apache Druid · Schema

Supervisor

An Apache Druid supervisor for managing continuous streaming data ingestion from Kafka or Kinesis.

AnalyticsApacheDatabaseKafkaOLAPOpen SourceReal-TimeSQLTime Series

Properties

Name	Type	Description
id	string	Supervisor ID (same as datasource name by convention).
state	string	Supervisor operational state.
healthStatus	string	Supervisor health status.
detailedState	string	Detailed supervisor sub-state.
spec	object	Full supervisor spec including ioConfig and tuningConfig.
lastTaskCompletionTime	string	When the last task completed.
activeTasks	integer	Number of currently active ingestion tasks.
publishingTasks	integer	Number of tasks publishing segments.

View JSON Schema on GitHub

JSON Schema

{
  "$schema": "https://json-schema.org/draft/2020-12/schema",
  "$id": "https://raw.githubusercontent.com/api-evangelist/apache-druid/refs/heads/main/json-schema/apache-druid-supervisor-schema.json",
  "title": "Supervisor",
  "description": "An Apache Druid supervisor for managing continuous streaming data ingestion from Kafka or Kinesis.",
  "type": "object",
  "properties": {
    "id": {
      "type": "string",
      "description": "Supervisor ID (same as datasource name by convention).",
      "example": "wikipedia-kafka"
    },
    "state": {
      "type": "string",
      "description": "Supervisor operational state.",
      "enum": [
        "PENDING",
        "RUNNING",
        "STOPPING",
        "STOPPED",
        "UNHEALTHY_SUPERVISOR",
        "UNHEALTHY_TASKS"
      ],
      "example": "RUNNING"
    },
    "healthStatus": {
      "type": "string",
      "description": "Supervisor health status.",
      "enum": [
        "HEALTHY",
        "UNHEALTHY"
      ],
      "example": "HEALTHY"
    },
    "detailedState": {
      "type": "string",
      "description": "Detailed supervisor sub-state.",
      "example": "RUNNING"
    },
    "spec": {
      "type": "object",
      "description": "Full supervisor spec including ioConfig and tuningConfig."
    },
    "lastTaskCompletionTime": {
      "type": "string",
      "format": "date-time",
      "description": "When the last task completed.",
      "example": "2025-03-15T14:30:00Z"
    },
    "activeTasks": {
      "type": "integer",
      "description": "Number of currently active ingestion tasks.",
      "example": 2
    },
    "publishingTasks": {
      "type": "integer",
      "description": "Number of tasks publishing segments.",
      "example": 0
    }
  }
}