Skip to main content

Stream Source Data

GET 
/sources/:sourceName/stream

Streams Predicti Source data in real-time using HTTP chunked responses.

Format Support: JSON and NDJSON formats via Accept header.

Connection: Automatically closes after 25 seconds of inactivity.

Offset Management (Automatic):

  • First-time streams: Start from the earliest available messages
  • Subsequent streams: Continue from where the previous stream left off
  • Offset tracking: Handled automatically by the endpoint - no client action required
  • Commit strategy: Offsets are committed only after successful delivery to client
  • Manual offset reset: Use the /v1/sources/:sourceName/offsets endpoint to reset the offset to a specific position

⚠️ IMPORTANT: Multiple concurrent streams for the same source name will cause duplicated data. Ensure only one stream is active per source name at a time.

Request​

Responses​

Stream started successfully

Response Headers
    Content-Type

    application/json or application/x-ndjson