STstreamkap
Sources

Bulk Execute Snapshot Sources

Execute snapshot on multiple sources in parallel.

Supports both incremental (default) and blocking snapshot types via the snapshot_type field:

  • incremental: Uses watermarking to capture data while streaming continues.
  • blocking: Pauses streaming during snapshot. Required for keyless tables. Executed with lower concurrency and staggered timing to avoid overwhelming Kafka Connect.

Supports two modes for source selection:

  1. Explicit IDs: Pass a list of source IDs
  2. Select all: Set select_all=true with optional filters

Returns partial success results - continues processing even if individual snapshots fail (e.g. 409 when a snapshot is already running for a source).

post/sources/bulk/snapshot

Request

Request body

idsstring[] nullable

List of entity IDs to perform the action on. Omit if using select_all=true.

select_allboolean

If true, select all entities matching the filters

snapshot_type'incremental' | 'blocking'

Type of snapshot to execute. 'incremental' (default) uses watermarking while streaming continues. 'blocking' pauses streaming during snapshot - required for keyless tables.

Response

Successful Response

Changes

No recorded changes to this operation across all 10 revisions of this API.