Skip to content
Streamkap
Esc
↑↓navigate↵open⌘Jpreview

Get latest raw metrics for a topic

Returns the latest raw metric values (per partition / task / context) from the ClickHouse metrics and metrics_qa tables for a single topic — bypassing the materialized-view aggregation that powers the lineage / observability surfaces.

Intended for debugging discrepancies between what raw CH holds and what the UI renders. Returns one row per (metric_name, partition, task, context); the caller is responsible for aggregating across partitions if needed (sum for lag, max for latency, etc.).

GET/topics/{topic_id}/raw-metrics
Authorization
AuthorizationBearer token · headerrequired
Path parameters
topic_idstringrequired
Query parameters
sincestring

Lookback window. Accepts '<int><unit>' where unit ∈ {s,m,h,d}. Defaults to 15m, capped at 3d (raw-table TTL).

default: "15m"
metric_namesstring | any

Comma-separated metric_name filter. Omit to return every metric_name seen in the window.

include_destinationsboolean
default: true
include_qaboolean
default: true
Responses
200

Successful Response

topic_idstringrequired
sincestring<date-time>required
sourceTopicRawConnectorMetrics | anyrequired
Show properties
Any of:
TopicRawConnectorMetrics
connectorstringrequired
ch_topicstringrequired
metricsTopicRawMetricRow[]required
Show properties
Array of TopicRawMetricRow
metric_namestringrequired
partitionstringrequired
taskstringrequired
contextstringrequired
valuenumberrequired
updated_atstring<date-time>required
any
any
destinationsTopicRawDestinationMetrics[]
Show properties
Array of TopicRawDestinationMetrics
destination_idstringrequired
connectorstringrequired
ch_topicstringrequired
pipeline_idstring | any
Show properties
Any of:
string
string
any
any
transform_idstring | any
Show properties
Any of:
string
string
any
any
metricsTopicRawMetricRow[]required
Show properties
Array of TopicRawMetricRow
metric_namestringrequired
partitionstringrequired
taskstringrequired
contextstringrequired
valuenumberrequired
updated_atstring<date-time>required
qaTopicRawQaRow[]
Show properties
Array of TopicRawQaRow
metric_namestringrequired
connector_ctxstringrequired
connector_idstringrequired
valuenumberrequired
updated_atstring<date-time>required
422

Validation Error

detailValidationError[]
Show properties
Array of ValidationError
locstring | integer[]required
Show properties
Array of string | integer
Any of:
string
string
integer
integer
msgstringrequired
typestringrequired
inputany
ctxobject
Request
curl -X GET "https://api.streamkap.com/topics/string/raw-metrics" \
  -H "Authorization: Bearer YOUR_TOKEN"
Response
{
  "topic_id": "string",
  "since": "2019-08-24T14:15:22Z",
  "source": {
    "connector": "string",
    "ch_topic": "string",
    "metrics": [
      {
        "metric_name": "string",
        "partition": "string",
        "task": "string",
        "context": "string",
        "value": 0,
        "updated_at": "2019-08-24T14:15:22Z"
      }
    ]
  },
  "destinations": [
    {
      "destination_id": "string",
      "connector": "string",
      "ch_topic": "string",
      "pipeline_id": "string",
      "transform_id": "string",
      "metrics": [
        {
          "metric_name": "string",
          "partition": "string",
          "task": "string",
          "context": "string",
          "value": 0,
          "updated_at": "2019-08-24T14:15:22Z"
        }
      ]
    }
  ],
  "qa": [
    {
      "metric_name": "string",
      "connector_ctx": "string",
      "connector_id": "string",
      "value": 0,
      "updated_at": "2019-08-24T14:15:22Z"
    }
  ]
}