TransformResponse

Result or current status of a transformation job

correlationIdstring<uuid>

Unique ID for this job — use to poll /status/{correlationId}

Example: 550e8400-e29b-41d4-a716-446655440000

statusstring

Job status

Possible values: [PENDING, RUNNING, COMPLETED, FAILED, PARTIAL]

Example: COMPLETED

specIdstring

ID of the spec used

Example: acme-payments-v2

fileNamestringnullable

Original file name (populated for file-upload jobs)

Example: payments_20240315.txt

totalRecordsinteger<int64>

Total records found in the source file

Example: 5000

successfulRecordsinteger<int64>

Records published to Kafka successfully

Example: 4987

failedRecordsinteger<int64>

Records that failed validation and were skipped (when skipInvalidRecords=true)

Example: 8

correctedRecordsinteger<int64>

Records that were auto-corrected before publishing

Example: 5

durationMsinteger<int64>

Total processing time in milliseconds

Example: 1243

messagestringnullable

Human-readable summary or error message

Example: Transformation complete with 8 failed records

errors object[]

Per-record validation errors (populated when skipInvalidRecords=true)

Array [

sequenceNumberinteger<int64>

1-based line/record number in the source file

Example: 42

fieldstringnullable

Field name that caused the error (null for record-level errors)

Example: amount

messagestring

Validation error message

Example: Amount must be non-negative

severitySeverity (string)

Severity level of a validation error

Possible values: [INFO, WARNING, ERROR, FATAL]

Example: ERROR

]

processedAtstring<date-time>

Example: 2024-03-15T10:30:00Z

TransformResponse

{
  "correlationId": "550e8400-e29b-41d4-a716-446655440000",
  "status": "COMPLETED",
  "specId": "acme-payments-v2",
  "fileName": "payments_20240315.txt",
  "totalRecords": 5000,
  "successfulRecords": 4987,
  "failedRecords": 8,
  "correctedRecords": 5,
  "durationMs": 1243,
  "message": "Transformation complete with 8 failed records",
  "errors": [
    {
      "sequenceNumber": 42,
      "field": "amount",
      "message": "Amount must be non-negative",
      "severity": "ERROR"
    }
  ],
  "processedAt": "2024-03-15T10:30:00Z"
}