Per-topic Kafka metadata for the topics list

curl --request POST \
  --url https://api.streamkap.com/topics/table_metrics \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data '
{
  "entities": [
    {
      "id": "<string>",
      "entity_type": "<string>",
      "connector": "<string>",
      "topic_ids": [
        "<string>"
      ],
      "topic_db_ids": [
        "<string>"
      ]
    }
  ]
}
'

{}

Topics

Per-topic Kafka metadata for the topics list

Returns per-topic Kafka broker metadata (partition_count, replication_factor, retention_ms) and lastMessageTimestamp, keyed by topic_id.

sources/transforms entities must carry matching topic_ids and topic_db_ids (used for ownership verification); such entities missing topic_db_ids return HTTP 400. destinations are exempt (send topic_db_ids: []) — they are verified against the destination’s topic_map. Topic names must match [a-zA-Z0-9._-]{1,249}; up to 1000 per entity.

All kafka.* fields are nullable — null means the broker did not return metadata for that topic, which is distinct from a legitimate 0. Values may be up to ~60 s stale for partition_count / replication_factor / retention_ms and up to ~10 s stale for lastMessageTimestamp.

POST

topics

table_metrics

Per-topic Kafka metadata for the topics list

curl --request POST \
  --url https://api.streamkap.com/topics/table_metrics \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data '
{
  "entities": [
    {
      "id": "<string>",
      "entity_type": "<string>",
      "connector": "<string>",
      "topic_ids": [
        "<string>"
      ],
      "topic_db_ids": [
        "<string>"
      ]
    }
  ]
}
'

{}

Authorizations

Authorization

string

header

required

Bearer authentication header of the form Bearer <token>, where <token> is your auth token.

Body

application/json

entities

SingleTopicTableMetricReq · object[]

required

List of entities (sources/destinations/transforms) with their topic IDs. sources/transforms entities that have topic_ids must also include topic_db_ids for ownership verification; otherwise the request returns HTTP 400. destinations are exempt (send topic_db_ids: []) — they are verified against the destination's topic_map.

Show child attributes

Response

Successful Response

{key}

TopicTableMetricsRowRes · object

Show child attributes

Get topic metrics Get topic messages

⌘I