Bulk Snapshot Topics

Execute snapshot for selected topics, grouped by their source connector.

Accepts topic DB IDs, resolves them to their source connectors, and triggers per-source snapshots scoped to only the selected topics (via topic_names).

Only topics produced by source connectors can be snapshotted - topics from transforms, destinations, or manually created topics are skipped.

Supports both incremental (default) and blocking snapshot types:

• incremental: Uses watermarking to capture data while streaming continues.
• blocking: Pauses streaming during snapshot. Required for keyless tables.

Results are reported per source connector, since snapshots are source-level operations. Returns partial success results - continues processing even if individual snapshots fail.

curl -X POST "https://api.streamkap.com/topics/bulk/snapshot" \
  -H "Authorization: Bearer YOUR_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
  "topic_ids": [
    "string"
  ],
  "snapshot_type": "incremental"
}'

const response = await fetch("https://api.streamkap.com/topics/bulk/snapshot", {
  method: "POST",
  headers: {
    "Authorization": "Bearer YOUR_TOKEN",
    "Content-Type": "application/json"
  },
  body: "{\n  \"topic_ids\": [\n    \"string\"\n  ],\n  \"snapshot_type\": \"incremental\"\n}"
});

import requests

response = requests.post(
    "https://api.streamkap.com/topics/bulk/snapshot",
    headers={
        "Authorization": "Bearer YOUR_TOKEN",
        "Content-Type": "application/json"
    },
    data="{\n  \"topic_ids\": [\n    \"string\"\n  ],\n  \"snapshot_type\": \"incremental\"\n}",
)

{
  "results": [
    {
      "id": "string",
      "success": true,
      "message": "string",
      "data": {}
    }
  ],
  "summary": {
    "total": 0,
    "succeeded": 0,
    "failed": 0
  }
}

{
  "detail": [
    {
      "loc": [
        "string"
      ],
      "msg": "string",
      "type": "string",
      "input": null,
      "ctx": {}
    }
  ]
}