Get Cluster Status

Get current cluster status by fetching live state from EKS + K8s.

Reads tier definitions from the cluster_configs collection, then queries the actual cluster to determine current tier, memory, and replicas. BYOC services without a cluster_configs record get a live-only view (no tier catalog, scaling_available: false) that degrades to ‘unknown’ values instead of failing.

GET/cluster/status

Authorization

AuthorizationBearer token · headerrequired

Responses

200

Successful Response

current_tierstringrequired

Currently active tier name (matched from K8s StatefulSet specs).

kafka_memorystringrequired

kafka_connect_memorystringrequired

kafka_connect_replicasintegerrequired

kafka_connect_statefulsetsKafkaConnectStatefulSetStatus[]

Per-StatefulSet live specs: one entry per Kafka Connect cluster the service runs.

Show properties

Array of KafkaConnectStatefulSetStatus

namestringrequired

memorystringrequired

replicasintegerrequired

tiersTierSpec[]

Every tier defined in the cluster's scaling configuration, ordered ascending by 'order'.

Show properties

Array of TierSpec

namestringrequired

orderintegerrequired

kafka_memorystringrequired

kafka_connect_memorystringrequired

kafka_connect_replicasintegerrequired

node_groupsTierNodeGroup[]

The Kafka node group plus every Kafka Connect node group across availability zones.

Show properties

Array of TierNodeGroup

rolestringrequired

'kafka' or 'kafka_connect'

namestringrequired

EKS node group name

azstring | null

Show properties

Any of:

string

string

null

null

instance_typestring | null

Show properties

Any of:

string

string

null

null

vcpu_per_nodeinteger | null

Show properties

Any of:

integer

integer

null

null

memory_gib_per_nodeinteger | null

Show properties

Any of:

integer

integer

null

null

nodesintegerrequired

Desired node count for this node group on this tier

statusstring | null

Live EKS node group status (e.g. ACTIVE). Only set on live reads.

Show properties

Any of:

string

string

null

null

ebs_volumesEbsVolumeStatus[]

EBS volumes attached per node. Populated for the Kafka node group only; Kafka Connect is stateless.

active_operation_idstring | null

Operation ID if a scaling operation is in progress

Show properties

Any of:

string

string

null

null

scaling_availableboolean

Whether scale operations are possible (the service has a scaling configuration). False for BYOC services rendered from live K8s state only.

default: true

live_node_groupsTierNodeGroup[]

Node groups read live from EKS/EC2 (with EBS volumes attached to the Kafka node group). Populated only on the config-less path, where no tier catalog exists.

Show properties

Array of TierNodeGroup

rolestringrequired

'kafka' or 'kafka_connect'

namestringrequired

EKS node group name

azstring | null

Show properties

Any of:

string

string

null

null

instance_typestring | null

Show properties

Any of:

string

string

null

null

vcpu_per_nodeinteger | null

Show properties

Any of:

integer

integer

null

null

memory_gib_per_nodeinteger | null

Show properties

Any of:

integer

integer

null

null

nodesintegerrequired

Desired node count for this node group on this tier

statusstring | null

Live EKS node group status (e.g. ACTIVE). Only set on live reads.

Show properties

Any of:

string

string

null

null

ebs_volumesEbsVolumeStatus[]

EBS volumes attached per node. Populated for the Kafka node group only; Kafka Connect is stateless.

Show properties

Array of EbsVolumeStatus

volume_typestringrequired

size_gbintegerrequired

iopsintegerrequired

throughput_mbpsinteger | null

Show properties

Any of:

integer

integer

null

null

volumes_per_nodeinteger

default: 1

Request

curl -X GET 'https://api.streamkap.com/cluster/status' \
  -H 'Authorization: Bearer YOUR_TOKEN' \
  -H 'Accept: application/json'

const response = await fetch("https://api.streamkap.com/cluster/status", {
  method: "GET",
  headers: {
    "Authorization": "Bearer YOUR_TOKEN",
    "Accept": "application/json"
  }
});

import requests

response = requests.get(
    "https://api.streamkap.com/cluster/status",
    headers={
        "Authorization": "Bearer YOUR_TOKEN",
        "Accept": "application/json"
    },
)

Response

{
  "current_tier": "string",
  "kafka_memory": "string",
  "kafka_connect_memory": "string",
  "kafka_connect_replicas": 0,
  "kafka_connect_statefulsets": [
    {
      "name": "string",
      "memory": "string",
      "replicas": 0
    }
  ],
  "tiers": [
    {
      "name": "string",
      "order": 0,
      "kafka_memory": "string",
      "kafka_connect_memory": "string",
      "kafka_connect_replicas": 0,
      "node_groups": [
        {
          "role": "string",
          "name": "string",
          "az": "string",
          "instance_type": "string",
          "vcpu_per_node": 0,
          "memory_gib_per_node": 0,
          "nodes": 0,
          "status": "string",
          "ebs_volumes": [
            {
              "volume_type": "string",
              "size_gb": 0,
              "iops": 0,
              "throughput_mbps": 0,
              "volumes_per_node": 1
            }
          ]
        }
      ]
    }
  ],
  "active_operation_id": "string",
  "scaling_available": true,
  "live_node_groups": [
    {
      "role": "string",
      "name": "string",
      "az": "string",
      "instance_type": "string",
      "vcpu_per_node": 0,
      "memory_gib_per_node": 0,
      "nodes": 0,
      "status": "string",
      "ebs_volumes": [
        {
          "volume_type": "string",
          "size_gb": 0,
          "iops": 0,
          "throughput_mbps": 0,
          "volumes_per_node": 1
        }
      ]
    }
  ]
}