diff --git a/src/modules/pipelinesV2/pipelines-client.ts b/src/modules/pipelinesV2/pipelines-client.ts index 53c0442..6330104 100644 --- a/src/modules/pipelinesV2/pipelines-client.ts +++ b/src/modules/pipelinesV2/pipelines-client.ts @@ -25,6 +25,10 @@ export class PipelinesClientConfiguration { loader: { keepCase: true, enums: String, + // int64 fields (PipelineV2SinkTableOffset.committed_offset) decode as + // plain JS numbers instead of Long.js objects, so they serialize as + // JSON numbers for the frontend. Safe: Kafka offsets fit in 2^53. + longs: Number, objects: true, arrays: true, },