Get Metrics For Sources - Streamkap Docs

Authorizations

Authorization

string

header

required

Bearer authentication header of the form Bearer <token>, where <token> is your auth token.

Query Parameters

string | null

topic_list_from

integer | null

topic_list_size

integer | null

from

size

integer | null

level

string | null

page

timestamp_to

timestamp_from

time_unit

string | null

time_interval

time_type

string | null

tenant_ids

string | null

A comma-separated list of Tenant IDs A comma-separated list of Tenant IDs

ids

string | null

A comma-separated list of source IDs A comma-separated list of source IDs

Response

Successful Response

Source metrics response.

account_metrics

Account Metrics · object

Show child attributes

account_metrics.{key}

SourceBaseMetrics · object

Source base metrics.

Show child attributes

account_metrics.{key}.timeseries

SourceTimeseriesMetrics · object

Source timeseries metrics.

Show child attributes

account_metrics.{key}.timeseries.SnapshotMilliSecondsSinceLastEvent

TimeseriesEntry · object[]

Show child attributes

account_metrics.{key}.timeseries.SnapshotMilliSecondsSinceLastEvent.value

required

account_metrics.{key}.timeseries.SnapshotMilliSecondsSinceLastEvent.timestamp

string

required

account_metrics.{key}.timeseries.SnapshotTotalNumberOfEventsSeen

TimeseriesEntry · object[]

Show child attributes

account_metrics.{key}.timeseries.SnapshotTotalNumberOfEventsSeen.value

required

account_metrics.{key}.timeseries.SnapshotTotalNumberOfEventsSeen.timestamp

string

required

account_metrics.{key}.timeseries.StreamingMilliSecondsBehindSource

TimeseriesEntry · object[]

Show child attributes

account_metrics.{key}.timeseries.StreamingMilliSecondsBehindSource.value

required

account_metrics.{key}.timeseries.StreamingMilliSecondsBehindSource.timestamp

string

required

account_metrics.{key}.timeseries.StreamingMilliSecondsSinceLastEvent

TimeseriesEntry · object[]

Show child attributes

account_metrics.{key}.timeseries.StreamingMilliSecondsSinceLastEvent.value

required

account_metrics.{key}.timeseries.StreamingMilliSecondsSinceLastEvent.timestamp

string

required

account_metrics.{key}.timeseries.StreamingTotalNumberOfCreateEventsSeen

TimeseriesEntry · object[]

Show child attributes

account_metrics.{key}.timeseries.StreamingTotalNumberOfCreateEventsSeen.value

required

account_metrics.{key}.timeseries.StreamingTotalNumberOfCreateEventsSeen.timestamp

string

required

account_metrics.{key}.timeseries.StreamingTotalNumberOfDeleteEventsSeen

TimeseriesEntry · object[]

Show child attributes

account_metrics.{key}.timeseries.StreamingTotalNumberOfDeleteEventsSeen.value

required

account_metrics.{key}.timeseries.StreamingTotalNumberOfDeleteEventsSeen.timestamp

string

required

account_metrics.{key}.timeseries.recordSendTotal

TimeseriesEntry · object[]

Show child attributes

account_metrics.{key}.timeseries.recordSendTotal.value

required

account_metrics.{key}.timeseries.recordSendTotal.timestamp

string

required

account_metrics.{key}.timeseries.StreamingTotalNumberOfUpdateEventsSeen

TimeseriesEntry · object[]

Show child attributes

account_metrics.{key}.timeseries.StreamingTotalNumberOfUpdateEventsSeen.value

required

account_metrics.{key}.timeseries.StreamingTotalNumberOfUpdateEventsSeen.timestamp

string

required

account_metrics.{key}.timeseries.recordRetryTotal

TimeseriesEntry · object[]

Show child attributes

account_metrics.{key}.timeseries.recordRetryTotal.value

required

account_metrics.{key}.timeseries.recordRetryTotal.timestamp

string

required

account_metrics.{key}.timeseries.recordWrittenTotal

TimeseriesEntry · object[]

Show child attributes

account_metrics.{key}.timeseries.recordWrittenTotal.value

required

account_metrics.{key}.timeseries.recordWrittenTotal.timestamp

string

required

account_metrics.{key}.timeseries.byteTotal

TimeseriesEntry · object[]

Show child attributes

account_metrics.{key}.timeseries.byteTotal.value

required

account_metrics.{key}.timeseries.byteTotal.timestamp

string

required

account_metrics.{key}.timeseries.sourceRecordWriteTotal

TimeseriesEntry · object[]

Show child attributes

account_metrics.{key}.timeseries.sourceRecordWriteTotal.value

required

account_metrics.{key}.timeseries.sourceRecordWriteTotal.timestamp

string

required

Example:

{
  "SnapshotMilliSecondsSinceLastEvent": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 500
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 300
    }
  ],
  "SnapshotTotalNumberOfEventsSeen": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 100
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 150
    }
  ],
  "StreamingMilliSecondsBehindSource": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 1000
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 800
    }
  ],
  "StreamingMilliSecondsSinceLastEvent": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 200
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 150
    }
  ],
  "StreamingTotalNumberOfCreateEventsSeen": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 20
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 35
    }
  ],
  "StreamingTotalNumberOfDeleteEventsSeen": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 5
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 8
    }
  ],
  "StreamingTotalNumberOfUpdateEventsSeen": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 30
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 45
    }
  ],
  "byteTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 10000
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 15000
    }
  ],
  "recordRetryTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 2
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 3
    }
  ],
  "recordSendTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 50
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 70
    }
  ],
  "recordWrittenTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 40
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 60
    }
  ],
  "sourceRecordWriteTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 25
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 40
    }
  ]
}

account_metrics.{key}.latest

SourceLatestMetrics · object

Source latest metrics.

Show child attributes

account_metrics.{key}.latest.SnapshotTotalNumberOfEventsSeen

account_metrics.{key}.latest.SnapshotMilliSecondsSinceLastEvent

account_metrics.{key}.latest.StreamingMilliSecondsBehindSource

account_metrics.{key}.latest.StreamingTotalNumberOfDeleteEventsSeen

account_metrics.{key}.latest.StreamingTotalNumberOfUpdateEventsSeen

account_metrics.{key}.latest.StreamingTotalNumberOfCreateEventsSeen

account_metrics.{key}.latest.StreamingMilliSecondsSinceLastEvent

account_metrics.{key}.latest.StreamingLastEvent

string | null

account_metrics.{key}.latest.recordRetryTotal

account_metrics.{key}.latest.byteTotal

account_metrics.{key}.latest.sourceRecordWriteTotal

account_metrics.{key}.latest.SnapshotRunning

account_metrics.{key}.latest.SnapshotCompleted

account_metrics.{key}.latest.StreamingConnected

account_metrics.{key}.latest.recordSendTotal

account_metrics.{key}.latest.state

string | null

account_metrics.{key}.latest.streamingState

string | null

account_metrics.{key}.latest.snapshotStatus

Snapshotstatus · object[] | null

Show child attributes

account_metrics.{key}.latest.snapshotStatus.{key}

account_metrics.{key}.latest.snapshotState

string | null

account_metrics.{key}.latest.recordWrittenTotal

account_metrics.{key}.latest.connector_status

string | null

account_metrics.{key}.latest.latency

Example:

{
  "SnapshotCompleted": 2,
  "SnapshotMilliSecondsSinceLastEvent": 3600000,
  "SnapshotRunning": 0,
  "SnapshotTotalNumberOfEventsSeen": 20254,
  "StreamingConnected": 1,
  "StreamingLastEvent": "position: {ord: 14}, key: {\"id\" : \"\"ceaafb88-2a60-4bd9-8515-719ba64ea05c-close\"\"}",
  "StreamingMilliSecondsBehindSource": 500,
  "StreamingMilliSecondsSinceLastEvent": 200,
  "StreamingTotalNumberOfCreateEventsSeen": 73,
  "StreamingTotalNumberOfDeleteEventsSeen": 312,
  "StreamingTotalNumberOfUpdateEventsSeen": 0,
  "byteTotal": 9018776,
  "connector_status": "Active",
  "latency": 150,
  "recordRetryTotal": 10,
  "recordSendTotal": 400,
  "recordWrittenTotal": 395,
  "snapshotState": "completed",
  "snapshotStatus": [
    {
      "status": "completed",
      "submit_timestamp": "2023-10-01T10:00:00Z",
      "topic_id": "source_111111111111111111111111.Test.test_data1"
    },
    {
      "status": "completed",
      "submit_timestamp": "2023-10-01T10:10:00Z",
      "topic_id": "source_111111111111111111111111.Test.test_data2"
    }
  ],
  "sourceRecordWriteTotal": 27785,
  "state": "Streaming",
  "streamingState": "connected"
}

account_metrics.{key}.timesummary

SourceTimesummaryMetrics · object

Source timesummary metrics.

Show child attributes

account_metrics.{key}.timesummary.SnapshotTotalNumberOfEventsSeen

account_metrics.{key}.timesummary.SnapshotMilliSecondsSinceLastEvent

account_metrics.{key}.timesummary.StreamingMilliSecondsBehindSource

account_metrics.{key}.timesummary.StreamingTotalNumberOfDeleteEventsSeen

account_metrics.{key}.timesummary.StreamingTotalNumberOfUpdateEventsSeen

account_metrics.{key}.timesummary.StreamingTotalNumberOfCreateEventsSeen

account_metrics.{key}.timesummary.StreamingMilliSecondsSinceLastEvent

account_metrics.{key}.timesummary.recordRetryTotal

account_metrics.{key}.timesummary.recordSendTotal

account_metrics.{key}.timesummary.recordWrittenTotal

account_metrics.{key}.timesummary.byteTotal

account_metrics.{key}.timesummary.sourceRecordWriteTotal

account_metrics.{key}.timesummary.snapshotStatus

Snapshotstatus · object[] | null

Show child attributes

account_metrics.{key}.timesummary.snapshotStatus.{key}

account_metrics.{key}.timesummary.snapshotState

string | null

account_metrics.{key}.timesummary.connector_status

string | null

account_metrics.{key}.timesummary.latency

Example:

{
  "SnapshotMilliSecondsSinceLastEvent": 500,
  "SnapshotTotalNumberOfEventsSeen": 65,
  "StreamingMilliSecondsBehindSource": 200,
  "StreamingMilliSecondsSinceLastEvent": 100,
  "StreamingTotalNumberOfCreateEventsSeen": 20,
  "StreamingTotalNumberOfDeleteEventsSeen": 13,
  "StreamingTotalNumberOfUpdateEventsSeen": 25,
  "byteTotal": 6000,
  "connector_status": "Active",
  "latency": 100,
  "recordRetryTotal": 5,
  "recordSendTotal": 60,
  "recordWrittenTotal": 58,
  "snapshotState": "completed",
  "snapshotStatus": [
    {
      "status": "completed",
      "submit_timestamp": "2023-10-01T12:00:00Z",
      "topic_id": "source_111111111111111111111111.Test.test_data1"
    },
    {
      "status": "completed",
      "submit_timestamp": "2023-10-01T12:05:00Z",
      "topic_id": "source_111111111111111111111111.Test.test_data2"
    }
  ],
  "sourceRecordWriteTotal": 547
}

connector_metrics

Connector Metrics · object

Show child attributes

connector_metrics.{key}

SourceBaseMetrics · object

Source base metrics.

Show child attributes

connector_metrics.{key}.timeseries

SourceTimeseriesMetrics · object

Source timeseries metrics.

Show child attributes

connector_metrics.{key}.timeseries.SnapshotMilliSecondsSinceLastEvent

TimeseriesEntry · object[]

Show child attributes

connector_metrics.{key}.timeseries.SnapshotMilliSecondsSinceLastEvent.value

required

connector_metrics.{key}.timeseries.SnapshotMilliSecondsSinceLastEvent.timestamp

string

required

connector_metrics.{key}.timeseries.SnapshotTotalNumberOfEventsSeen

TimeseriesEntry · object[]

Show child attributes

connector_metrics.{key}.timeseries.SnapshotTotalNumberOfEventsSeen.value

required

connector_metrics.{key}.timeseries.SnapshotTotalNumberOfEventsSeen.timestamp

string

required

connector_metrics.{key}.timeseries.StreamingMilliSecondsBehindSource

TimeseriesEntry · object[]

Show child attributes

connector_metrics.{key}.timeseries.StreamingMilliSecondsBehindSource.value

required

connector_metrics.{key}.timeseries.StreamingMilliSecondsBehindSource.timestamp

string

required

connector_metrics.{key}.timeseries.StreamingMilliSecondsSinceLastEvent

TimeseriesEntry · object[]

Show child attributes

connector_metrics.{key}.timeseries.StreamingMilliSecondsSinceLastEvent.value

required

connector_metrics.{key}.timeseries.StreamingMilliSecondsSinceLastEvent.timestamp

string

required

connector_metrics.{key}.timeseries.StreamingTotalNumberOfCreateEventsSeen

TimeseriesEntry · object[]

Show child attributes

connector_metrics.{key}.timeseries.StreamingTotalNumberOfCreateEventsSeen.value

required

connector_metrics.{key}.timeseries.StreamingTotalNumberOfCreateEventsSeen.timestamp

string

required

connector_metrics.{key}.timeseries.StreamingTotalNumberOfDeleteEventsSeen

TimeseriesEntry · object[]

Show child attributes

connector_metrics.{key}.timeseries.StreamingTotalNumberOfDeleteEventsSeen.value

required

connector_metrics.{key}.timeseries.StreamingTotalNumberOfDeleteEventsSeen.timestamp

string

required

connector_metrics.{key}.timeseries.recordSendTotal

TimeseriesEntry · object[]

Show child attributes

connector_metrics.{key}.timeseries.recordSendTotal.value

required

connector_metrics.{key}.timeseries.recordSendTotal.timestamp

string

required

connector_metrics.{key}.timeseries.StreamingTotalNumberOfUpdateEventsSeen

TimeseriesEntry · object[]

Show child attributes

connector_metrics.{key}.timeseries.StreamingTotalNumberOfUpdateEventsSeen.value

required

connector_metrics.{key}.timeseries.StreamingTotalNumberOfUpdateEventsSeen.timestamp

string

required

connector_metrics.{key}.timeseries.recordRetryTotal

TimeseriesEntry · object[]

Show child attributes

connector_metrics.{key}.timeseries.recordRetryTotal.value

required

connector_metrics.{key}.timeseries.recordRetryTotal.timestamp

string

required

connector_metrics.{key}.timeseries.recordWrittenTotal

TimeseriesEntry · object[]

Show child attributes

connector_metrics.{key}.timeseries.recordWrittenTotal.value

required

connector_metrics.{key}.timeseries.recordWrittenTotal.timestamp

string

required

connector_metrics.{key}.timeseries.byteTotal

TimeseriesEntry · object[]

Show child attributes

connector_metrics.{key}.timeseries.byteTotal.value

required

connector_metrics.{key}.timeseries.byteTotal.timestamp

string

required

connector_metrics.{key}.timeseries.sourceRecordWriteTotal

TimeseriesEntry · object[]

Show child attributes

connector_metrics.{key}.timeseries.sourceRecordWriteTotal.value

required

connector_metrics.{key}.timeseries.sourceRecordWriteTotal.timestamp

string

required

Example:

{
  "SnapshotMilliSecondsSinceLastEvent": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 500
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 300
    }
  ],
  "SnapshotTotalNumberOfEventsSeen": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 100
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 150
    }
  ],
  "StreamingMilliSecondsBehindSource": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 1000
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 800
    }
  ],
  "StreamingMilliSecondsSinceLastEvent": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 200
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 150
    }
  ],
  "StreamingTotalNumberOfCreateEventsSeen": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 20
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 35
    }
  ],
  "StreamingTotalNumberOfDeleteEventsSeen": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 5
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 8
    }
  ],
  "StreamingTotalNumberOfUpdateEventsSeen": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 30
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 45
    }
  ],
  "byteTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 10000
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 15000
    }
  ],
  "recordRetryTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 2
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 3
    }
  ],
  "recordSendTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 50
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 70
    }
  ],
  "recordWrittenTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 40
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 60
    }
  ],
  "sourceRecordWriteTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 25
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 40
    }
  ]
}

connector_metrics.{key}.latest

SourceLatestMetrics · object

Source latest metrics.

Show child attributes

connector_metrics.{key}.latest.SnapshotTotalNumberOfEventsSeen

connector_metrics.{key}.latest.SnapshotMilliSecondsSinceLastEvent

connector_metrics.{key}.latest.StreamingMilliSecondsBehindSource

connector_metrics.{key}.latest.StreamingTotalNumberOfDeleteEventsSeen

connector_metrics.{key}.latest.StreamingTotalNumberOfUpdateEventsSeen

connector_metrics.{key}.latest.StreamingTotalNumberOfCreateEventsSeen

connector_metrics.{key}.latest.StreamingMilliSecondsSinceLastEvent

connector_metrics.{key}.latest.StreamingLastEvent

string | null

connector_metrics.{key}.latest.recordRetryTotal

connector_metrics.{key}.latest.byteTotal

connector_metrics.{key}.latest.sourceRecordWriteTotal

connector_metrics.{key}.latest.SnapshotRunning

connector_metrics.{key}.latest.SnapshotCompleted

connector_metrics.{key}.latest.StreamingConnected

connector_metrics.{key}.latest.recordSendTotal

connector_metrics.{key}.latest.state

string | null

connector_metrics.{key}.latest.streamingState

string | null

connector_metrics.{key}.latest.snapshotStatus

Snapshotstatus · object[] | null

Show child attributes

connector_metrics.{key}.latest.snapshotStatus.{key}

connector_metrics.{key}.latest.snapshotState

string | null

connector_metrics.{key}.latest.recordWrittenTotal

connector_metrics.{key}.latest.connector_status

string | null

connector_metrics.{key}.latest.latency

Example:

{
  "SnapshotCompleted": 2,
  "SnapshotMilliSecondsSinceLastEvent": 3600000,
  "SnapshotRunning": 0,
  "SnapshotTotalNumberOfEventsSeen": 20254,
  "StreamingConnected": 1,
  "StreamingLastEvent": "position: {ord: 14}, key: {\"id\" : \"\"ceaafb88-2a60-4bd9-8515-719ba64ea05c-close\"\"}",
  "StreamingMilliSecondsBehindSource": 500,
  "StreamingMilliSecondsSinceLastEvent": 200,
  "StreamingTotalNumberOfCreateEventsSeen": 73,
  "StreamingTotalNumberOfDeleteEventsSeen": 312,
  "StreamingTotalNumberOfUpdateEventsSeen": 0,
  "byteTotal": 9018776,
  "connector_status": "Active",
  "latency": 150,
  "recordRetryTotal": 10,
  "recordSendTotal": 400,
  "recordWrittenTotal": 395,
  "snapshotState": "completed",
  "snapshotStatus": [
    {
      "status": "completed",
      "submit_timestamp": "2023-10-01T10:00:00Z",
      "topic_id": "source_111111111111111111111111.Test.test_data1"
    },
    {
      "status": "completed",
      "submit_timestamp": "2023-10-01T10:10:00Z",
      "topic_id": "source_111111111111111111111111.Test.test_data2"
    }
  ],
  "sourceRecordWriteTotal": 27785,
  "state": "Streaming",
  "streamingState": "connected"
}

connector_metrics.{key}.timesummary

SourceTimesummaryMetrics · object

Source timesummary metrics.

Show child attributes

connector_metrics.{key}.timesummary.SnapshotTotalNumberOfEventsSeen

connector_metrics.{key}.timesummary.SnapshotMilliSecondsSinceLastEvent

connector_metrics.{key}.timesummary.StreamingMilliSecondsBehindSource

connector_metrics.{key}.timesummary.StreamingTotalNumberOfDeleteEventsSeen

connector_metrics.{key}.timesummary.StreamingTotalNumberOfUpdateEventsSeen

connector_metrics.{key}.timesummary.StreamingTotalNumberOfCreateEventsSeen

connector_metrics.{key}.timesummary.StreamingMilliSecondsSinceLastEvent

connector_metrics.{key}.timesummary.recordRetryTotal

connector_metrics.{key}.timesummary.recordSendTotal

connector_metrics.{key}.timesummary.recordWrittenTotal

connector_metrics.{key}.timesummary.byteTotal

connector_metrics.{key}.timesummary.sourceRecordWriteTotal

connector_metrics.{key}.timesummary.snapshotStatus

Snapshotstatus · object[] | null

Show child attributes

connector_metrics.{key}.timesummary.snapshotStatus.{key}

connector_metrics.{key}.timesummary.snapshotState

string | null

connector_metrics.{key}.timesummary.connector_status

string | null

connector_metrics.{key}.timesummary.latency

Example:

{
  "SnapshotMilliSecondsSinceLastEvent": 500,
  "SnapshotTotalNumberOfEventsSeen": 65,
  "StreamingMilliSecondsBehindSource": 200,
  "StreamingMilliSecondsSinceLastEvent": 100,
  "StreamingTotalNumberOfCreateEventsSeen": 20,
  "StreamingTotalNumberOfDeleteEventsSeen": 13,
  "StreamingTotalNumberOfUpdateEventsSeen": 25,
  "byteTotal": 6000,
  "connector_status": "Active",
  "latency": 100,
  "recordRetryTotal": 5,
  "recordSendTotal": 60,
  "recordWrittenTotal": 58,
  "snapshotState": "completed",
  "snapshotStatus": [
    {
      "status": "completed",
      "submit_timestamp": "2023-10-01T12:00:00Z",
      "topic_id": "source_111111111111111111111111.Test.test_data1"
    },
    {
      "status": "completed",
      "submit_timestamp": "2023-10-01T12:05:00Z",
      "topic_id": "source_111111111111111111111111.Test.test_data2"
    }
  ],
  "sourceRecordWriteTotal": 547
}

inline_metrics

Inline Metrics · object

Show child attributes

inline_metrics.{key}

SourceBaseMetrics · object

Source base metrics.

Show child attributes

inline_metrics.{key}.timeseries

SourceTimeseriesMetrics · object

Source timeseries metrics.

Show child attributes

inline_metrics.{key}.timeseries.SnapshotMilliSecondsSinceLastEvent

TimeseriesEntry · object[]

Show child attributes

inline_metrics.{key}.timeseries.SnapshotMilliSecondsSinceLastEvent.value

required

inline_metrics.{key}.timeseries.SnapshotMilliSecondsSinceLastEvent.timestamp

string

required

inline_metrics.{key}.timeseries.SnapshotTotalNumberOfEventsSeen

TimeseriesEntry · object[]

Show child attributes

inline_metrics.{key}.timeseries.SnapshotTotalNumberOfEventsSeen.value

required

inline_metrics.{key}.timeseries.SnapshotTotalNumberOfEventsSeen.timestamp

string

required

inline_metrics.{key}.timeseries.StreamingMilliSecondsBehindSource

TimeseriesEntry · object[]

Show child attributes

inline_metrics.{key}.timeseries.StreamingMilliSecondsBehindSource.value

required

inline_metrics.{key}.timeseries.StreamingMilliSecondsBehindSource.timestamp

string

required

inline_metrics.{key}.timeseries.StreamingMilliSecondsSinceLastEvent

TimeseriesEntry · object[]

Show child attributes

inline_metrics.{key}.timeseries.StreamingMilliSecondsSinceLastEvent.value

required

inline_metrics.{key}.timeseries.StreamingMilliSecondsSinceLastEvent.timestamp

string

required

inline_metrics.{key}.timeseries.StreamingTotalNumberOfCreateEventsSeen

TimeseriesEntry · object[]

Show child attributes

inline_metrics.{key}.timeseries.StreamingTotalNumberOfCreateEventsSeen.value

required

inline_metrics.{key}.timeseries.StreamingTotalNumberOfCreateEventsSeen.timestamp

string

required

inline_metrics.{key}.timeseries.StreamingTotalNumberOfDeleteEventsSeen

TimeseriesEntry · object[]

Show child attributes

inline_metrics.{key}.timeseries.StreamingTotalNumberOfDeleteEventsSeen.value

required

inline_metrics.{key}.timeseries.StreamingTotalNumberOfDeleteEventsSeen.timestamp

string

required

inline_metrics.{key}.timeseries.recordSendTotal

TimeseriesEntry · object[]

Show child attributes

inline_metrics.{key}.timeseries.recordSendTotal.value

required

inline_metrics.{key}.timeseries.recordSendTotal.timestamp

string

required

inline_metrics.{key}.timeseries.StreamingTotalNumberOfUpdateEventsSeen

TimeseriesEntry · object[]

Show child attributes

inline_metrics.{key}.timeseries.StreamingTotalNumberOfUpdateEventsSeen.value

required

inline_metrics.{key}.timeseries.StreamingTotalNumberOfUpdateEventsSeen.timestamp

string

required

inline_metrics.{key}.timeseries.recordRetryTotal

TimeseriesEntry · object[]

Show child attributes

inline_metrics.{key}.timeseries.recordRetryTotal.value

required

inline_metrics.{key}.timeseries.recordRetryTotal.timestamp

string

required

inline_metrics.{key}.timeseries.recordWrittenTotal

TimeseriesEntry · object[]

Show child attributes

inline_metrics.{key}.timeseries.recordWrittenTotal.value

required

inline_metrics.{key}.timeseries.recordWrittenTotal.timestamp

string

required

inline_metrics.{key}.timeseries.byteTotal

TimeseriesEntry · object[]

Show child attributes

inline_metrics.{key}.timeseries.byteTotal.value

required

inline_metrics.{key}.timeseries.byteTotal.timestamp

string

required

inline_metrics.{key}.timeseries.sourceRecordWriteTotal

TimeseriesEntry · object[]

Show child attributes

inline_metrics.{key}.timeseries.sourceRecordWriteTotal.value

required

inline_metrics.{key}.timeseries.sourceRecordWriteTotal.timestamp

string

required

Example:

{
  "SnapshotMilliSecondsSinceLastEvent": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 500
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 300
    }
  ],
  "SnapshotTotalNumberOfEventsSeen": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 100
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 150
    }
  ],
  "StreamingMilliSecondsBehindSource": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 1000
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 800
    }
  ],
  "StreamingMilliSecondsSinceLastEvent": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 200
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 150
    }
  ],
  "StreamingTotalNumberOfCreateEventsSeen": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 20
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 35
    }
  ],
  "StreamingTotalNumberOfDeleteEventsSeen": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 5
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 8
    }
  ],
  "StreamingTotalNumberOfUpdateEventsSeen": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 30
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 45
    }
  ],
  "byteTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 10000
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 15000
    }
  ],
  "recordRetryTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 2
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 3
    }
  ],
  "recordSendTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 50
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 70
    }
  ],
  "recordWrittenTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 40
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 60
    }
  ],
  "sourceRecordWriteTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 25
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 40
    }
  ]
}

inline_metrics.{key}.latest

SourceLatestMetrics · object

Source latest metrics.

Show child attributes

inline_metrics.{key}.latest.SnapshotTotalNumberOfEventsSeen

inline_metrics.{key}.latest.SnapshotMilliSecondsSinceLastEvent

inline_metrics.{key}.latest.StreamingMilliSecondsBehindSource

inline_metrics.{key}.latest.StreamingTotalNumberOfDeleteEventsSeen

inline_metrics.{key}.latest.StreamingTotalNumberOfUpdateEventsSeen

inline_metrics.{key}.latest.StreamingTotalNumberOfCreateEventsSeen

inline_metrics.{key}.latest.StreamingMilliSecondsSinceLastEvent

inline_metrics.{key}.latest.StreamingLastEvent

string | null

inline_metrics.{key}.latest.recordRetryTotal

inline_metrics.{key}.latest.byteTotal

inline_metrics.{key}.latest.sourceRecordWriteTotal

inline_metrics.{key}.latest.SnapshotRunning

inline_metrics.{key}.latest.SnapshotCompleted

inline_metrics.{key}.latest.StreamingConnected

inline_metrics.{key}.latest.recordSendTotal

inline_metrics.{key}.latest.state

string | null

inline_metrics.{key}.latest.streamingState

string | null

inline_metrics.{key}.latest.snapshotStatus

Snapshotstatus · object[] | null

Show child attributes

inline_metrics.{key}.latest.snapshotStatus.{key}

inline_metrics.{key}.latest.snapshotState

string | null

inline_metrics.{key}.latest.recordWrittenTotal

inline_metrics.{key}.latest.connector_status

string | null

inline_metrics.{key}.latest.latency

Example:

{
  "SnapshotCompleted": 2,
  "SnapshotMilliSecondsSinceLastEvent": 3600000,
  "SnapshotRunning": 0,
  "SnapshotTotalNumberOfEventsSeen": 20254,
  "StreamingConnected": 1,
  "StreamingLastEvent": "position: {ord: 14}, key: {\"id\" : \"\"ceaafb88-2a60-4bd9-8515-719ba64ea05c-close\"\"}",
  "StreamingMilliSecondsBehindSource": 500,
  "StreamingMilliSecondsSinceLastEvent": 200,
  "StreamingTotalNumberOfCreateEventsSeen": 73,
  "StreamingTotalNumberOfDeleteEventsSeen": 312,
  "StreamingTotalNumberOfUpdateEventsSeen": 0,
  "byteTotal": 9018776,
  "connector_status": "Active",
  "latency": 150,
  "recordRetryTotal": 10,
  "recordSendTotal": 400,
  "recordWrittenTotal": 395,
  "snapshotState": "completed",
  "snapshotStatus": [
    {
      "status": "completed",
      "submit_timestamp": "2023-10-01T10:00:00Z",
      "topic_id": "source_111111111111111111111111.Test.test_data1"
    },
    {
      "status": "completed",
      "submit_timestamp": "2023-10-01T10:10:00Z",
      "topic_id": "source_111111111111111111111111.Test.test_data2"
    }
  ],
  "sourceRecordWriteTotal": 27785,
  "state": "Streaming",
  "streamingState": "connected"
}

inline_metrics.{key}.timesummary

SourceTimesummaryMetrics · object

Source timesummary metrics.

Show child attributes

inline_metrics.{key}.timesummary.SnapshotTotalNumberOfEventsSeen

inline_metrics.{key}.timesummary.SnapshotMilliSecondsSinceLastEvent

inline_metrics.{key}.timesummary.StreamingMilliSecondsBehindSource

inline_metrics.{key}.timesummary.StreamingTotalNumberOfDeleteEventsSeen

inline_metrics.{key}.timesummary.StreamingTotalNumberOfUpdateEventsSeen

inline_metrics.{key}.timesummary.StreamingTotalNumberOfCreateEventsSeen

inline_metrics.{key}.timesummary.StreamingMilliSecondsSinceLastEvent

inline_metrics.{key}.timesummary.recordRetryTotal

inline_metrics.{key}.timesummary.recordSendTotal

inline_metrics.{key}.timesummary.recordWrittenTotal

inline_metrics.{key}.timesummary.byteTotal

inline_metrics.{key}.timesummary.sourceRecordWriteTotal

inline_metrics.{key}.timesummary.snapshotStatus

Snapshotstatus · object[] | null

Show child attributes

inline_metrics.{key}.timesummary.snapshotStatus.{key}

inline_metrics.{key}.timesummary.snapshotState

string | null

inline_metrics.{key}.timesummary.connector_status

string | null

inline_metrics.{key}.timesummary.latency

Example:

{
  "SnapshotMilliSecondsSinceLastEvent": 500,
  "SnapshotTotalNumberOfEventsSeen": 65,
  "StreamingMilliSecondsBehindSource": 200,
  "StreamingMilliSecondsSinceLastEvent": 100,
  "StreamingTotalNumberOfCreateEventsSeen": 20,
  "StreamingTotalNumberOfDeleteEventsSeen": 13,
  "StreamingTotalNumberOfUpdateEventsSeen": 25,
  "byteTotal": 6000,
  "connector_status": "Active",
  "latency": 100,
  "recordRetryTotal": 5,
  "recordSendTotal": 60,
  "recordWrittenTotal": 58,
  "snapshotState": "completed",
  "snapshotStatus": [
    {
      "status": "completed",
      "submit_timestamp": "2023-10-01T12:00:00Z",
      "topic_id": "source_111111111111111111111111.Test.test_data1"
    },
    {
      "status": "completed",
      "submit_timestamp": "2023-10-01T12:05:00Z",
      "topic_id": "source_111111111111111111111111.Test.test_data2"
    }
  ],
  "sourceRecordWriteTotal": 547
}

task_metrics

Task Metrics · object

Show child attributes

task_metrics.{key}

object

Show child attributes

task_metrics.{key}.{key}

SourceBaseMetrics · object

Source base metrics.

Show child attributes

task_metrics.{key}.{key}.timeseries

SourceTimeseriesMetrics · object

Source timeseries metrics.

Show child attributes

task_metrics.{key}.{key}.timeseries.SnapshotMilliSecondsSinceLastEvent

TimeseriesEntry · object[]

Show child attributes

task_metrics.{key}.{key}.timeseries.SnapshotMilliSecondsSinceLastEvent.value

required

task_metrics.{key}.{key}.timeseries.SnapshotMilliSecondsSinceLastEvent.timestamp

string

required

task_metrics.{key}.{key}.timeseries.SnapshotTotalNumberOfEventsSeen

TimeseriesEntry · object[]

Show child attributes

task_metrics.{key}.{key}.timeseries.SnapshotTotalNumberOfEventsSeen.value

required

task_metrics.{key}.{key}.timeseries.SnapshotTotalNumberOfEventsSeen.timestamp

string

required

task_metrics.{key}.{key}.timeseries.StreamingMilliSecondsBehindSource

TimeseriesEntry · object[]

Show child attributes

task_metrics.{key}.{key}.timeseries.StreamingMilliSecondsBehindSource.value

required

task_metrics.{key}.{key}.timeseries.StreamingMilliSecondsBehindSource.timestamp

string

required

task_metrics.{key}.{key}.timeseries.StreamingMilliSecondsSinceLastEvent

TimeseriesEntry · object[]

Show child attributes

task_metrics.{key}.{key}.timeseries.StreamingMilliSecondsSinceLastEvent.value

required

task_metrics.{key}.{key}.timeseries.StreamingMilliSecondsSinceLastEvent.timestamp

string

required

task_metrics.{key}.{key}.timeseries.StreamingTotalNumberOfCreateEventsSeen

TimeseriesEntry · object[]

Show child attributes

task_metrics.{key}.{key}.timeseries.StreamingTotalNumberOfCreateEventsSeen.value

required

task_metrics.{key}.{key}.timeseries.StreamingTotalNumberOfCreateEventsSeen.timestamp

string

required

task_metrics.{key}.{key}.timeseries.StreamingTotalNumberOfDeleteEventsSeen

TimeseriesEntry · object[]

Show child attributes

task_metrics.{key}.{key}.timeseries.StreamingTotalNumberOfDeleteEventsSeen.value

required

task_metrics.{key}.{key}.timeseries.StreamingTotalNumberOfDeleteEventsSeen.timestamp

string

required

task_metrics.{key}.{key}.timeseries.recordSendTotal

TimeseriesEntry · object[]

Show child attributes

task_metrics.{key}.{key}.timeseries.recordSendTotal.value

required

task_metrics.{key}.{key}.timeseries.recordSendTotal.timestamp

string

required

task_metrics.{key}.{key}.timeseries.StreamingTotalNumberOfUpdateEventsSeen

TimeseriesEntry · object[]

Show child attributes

task_metrics.{key}.{key}.timeseries.StreamingTotalNumberOfUpdateEventsSeen.value

required

task_metrics.{key}.{key}.timeseries.StreamingTotalNumberOfUpdateEventsSeen.timestamp

string

required

task_metrics.{key}.{key}.timeseries.recordRetryTotal

TimeseriesEntry · object[]

Show child attributes

task_metrics.{key}.{key}.timeseries.recordRetryTotal.value

required

task_metrics.{key}.{key}.timeseries.recordRetryTotal.timestamp

string

required

task_metrics.{key}.{key}.timeseries.recordWrittenTotal

TimeseriesEntry · object[]

Show child attributes

task_metrics.{key}.{key}.timeseries.recordWrittenTotal.value

required

task_metrics.{key}.{key}.timeseries.recordWrittenTotal.timestamp

string

required

task_metrics.{key}.{key}.timeseries.byteTotal

TimeseriesEntry · object[]

Show child attributes

task_metrics.{key}.{key}.timeseries.byteTotal.value

required

task_metrics.{key}.{key}.timeseries.byteTotal.timestamp

string

required

task_metrics.{key}.{key}.timeseries.sourceRecordWriteTotal

TimeseriesEntry · object[]

Show child attributes

task_metrics.{key}.{key}.timeseries.sourceRecordWriteTotal.value

required

task_metrics.{key}.{key}.timeseries.sourceRecordWriteTotal.timestamp

string

required

Example:

{
  "SnapshotMilliSecondsSinceLastEvent": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 500
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 300
    }
  ],
  "SnapshotTotalNumberOfEventsSeen": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 100
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 150
    }
  ],
  "StreamingMilliSecondsBehindSource": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 1000
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 800
    }
  ],
  "StreamingMilliSecondsSinceLastEvent": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 200
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 150
    }
  ],
  "StreamingTotalNumberOfCreateEventsSeen": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 20
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 35
    }
  ],
  "StreamingTotalNumberOfDeleteEventsSeen": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 5
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 8
    }
  ],
  "StreamingTotalNumberOfUpdateEventsSeen": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 30
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 45
    }
  ],
  "byteTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 10000
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 15000
    }
  ],
  "recordRetryTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 2
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 3
    }
  ],
  "recordSendTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 50
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 70
    }
  ],
  "recordWrittenTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 40
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 60
    }
  ],
  "sourceRecordWriteTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 25
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 40
    }
  ]
}

task_metrics.{key}.{key}.latest

SourceLatestMetrics · object

Source latest metrics.

Show child attributes

task_metrics.{key}.{key}.latest.SnapshotTotalNumberOfEventsSeen

task_metrics.{key}.{key}.latest.SnapshotMilliSecondsSinceLastEvent

task_metrics.{key}.{key}.latest.StreamingMilliSecondsBehindSource

task_metrics.{key}.{key}.latest.StreamingTotalNumberOfDeleteEventsSeen

task_metrics.{key}.{key}.latest.StreamingTotalNumberOfUpdateEventsSeen

task_metrics.{key}.{key}.latest.StreamingTotalNumberOfCreateEventsSeen

task_metrics.{key}.{key}.latest.StreamingMilliSecondsSinceLastEvent

task_metrics.{key}.{key}.latest.StreamingLastEvent

string | null

task_metrics.{key}.{key}.latest.recordRetryTotal

task_metrics.{key}.{key}.latest.byteTotal

task_metrics.{key}.{key}.latest.sourceRecordWriteTotal

task_metrics.{key}.{key}.latest.SnapshotRunning

task_metrics.{key}.{key}.latest.SnapshotCompleted

task_metrics.{key}.{key}.latest.StreamingConnected

task_metrics.{key}.{key}.latest.recordSendTotal

task_metrics.{key}.{key}.latest.state

string | null

task_metrics.{key}.{key}.latest.streamingState

string | null

task_metrics.{key}.{key}.latest.snapshotStatus

Snapshotstatus · object[] | null

Show child attributes

task_metrics.{key}.{key}.latest.snapshotStatus.{key}

task_metrics.{key}.{key}.latest.snapshotState

string | null

task_metrics.{key}.{key}.latest.recordWrittenTotal

task_metrics.{key}.{key}.latest.connector_status

string | null

task_metrics.{key}.{key}.latest.latency

Example:

{
  "SnapshotCompleted": 2,
  "SnapshotMilliSecondsSinceLastEvent": 3600000,
  "SnapshotRunning": 0,
  "SnapshotTotalNumberOfEventsSeen": 20254,
  "StreamingConnected": 1,
  "StreamingLastEvent": "position: {ord: 14}, key: {\"id\" : \"\"ceaafb88-2a60-4bd9-8515-719ba64ea05c-close\"\"}",
  "StreamingMilliSecondsBehindSource": 500,
  "StreamingMilliSecondsSinceLastEvent": 200,
  "StreamingTotalNumberOfCreateEventsSeen": 73,
  "StreamingTotalNumberOfDeleteEventsSeen": 312,
  "StreamingTotalNumberOfUpdateEventsSeen": 0,
  "byteTotal": 9018776,
  "connector_status": "Active",
  "latency": 150,
  "recordRetryTotal": 10,
  "recordSendTotal": 400,
  "recordWrittenTotal": 395,
  "snapshotState": "completed",
  "snapshotStatus": [
    {
      "status": "completed",
      "submit_timestamp": "2023-10-01T10:00:00Z",
      "topic_id": "source_111111111111111111111111.Test.test_data1"
    },
    {
      "status": "completed",
      "submit_timestamp": "2023-10-01T10:10:00Z",
      "topic_id": "source_111111111111111111111111.Test.test_data2"
    }
  ],
  "sourceRecordWriteTotal": 27785,
  "state": "Streaming",
  "streamingState": "connected"
}

task_metrics.{key}.{key}.timesummary

SourceTimesummaryMetrics · object

Source timesummary metrics.

Show child attributes

task_metrics.{key}.{key}.timesummary.SnapshotTotalNumberOfEventsSeen

task_metrics.{key}.{key}.timesummary.SnapshotMilliSecondsSinceLastEvent

task_metrics.{key}.{key}.timesummary.StreamingMilliSecondsBehindSource

task_metrics.{key}.{key}.timesummary.StreamingTotalNumberOfDeleteEventsSeen

task_metrics.{key}.{key}.timesummary.StreamingTotalNumberOfUpdateEventsSeen

task_metrics.{key}.{key}.timesummary.StreamingTotalNumberOfCreateEventsSeen

task_metrics.{key}.{key}.timesummary.StreamingMilliSecondsSinceLastEvent

task_metrics.{key}.{key}.timesummary.recordRetryTotal

task_metrics.{key}.{key}.timesummary.recordSendTotal

task_metrics.{key}.{key}.timesummary.recordWrittenTotal

task_metrics.{key}.{key}.timesummary.byteTotal

task_metrics.{key}.{key}.timesummary.sourceRecordWriteTotal

task_metrics.{key}.{key}.timesummary.snapshotStatus

Snapshotstatus · object[] | null

Show child attributes

task_metrics.{key}.{key}.timesummary.snapshotStatus.{key}

task_metrics.{key}.{key}.timesummary.snapshotState

string | null

task_metrics.{key}.{key}.timesummary.connector_status

string | null

task_metrics.{key}.{key}.timesummary.latency

Example:

{
  "SnapshotMilliSecondsSinceLastEvent": 500,
  "SnapshotTotalNumberOfEventsSeen": 65,
  "StreamingMilliSecondsBehindSource": 200,
  "StreamingMilliSecondsSinceLastEvent": 100,
  "StreamingTotalNumberOfCreateEventsSeen": 20,
  "StreamingTotalNumberOfDeleteEventsSeen": 13,
  "StreamingTotalNumberOfUpdateEventsSeen": 25,
  "byteTotal": 6000,
  "connector_status": "Active",
  "latency": 100,
  "recordRetryTotal": 5,
  "recordSendTotal": 60,
  "recordWrittenTotal": 58,
  "snapshotState": "completed",
  "snapshotStatus": [
    {
      "status": "completed",
      "submit_timestamp": "2023-10-01T12:00:00Z",
      "topic_id": "source_111111111111111111111111.Test.test_data1"
    },
    {
      "status": "completed",
      "submit_timestamp": "2023-10-01T12:05:00Z",
      "topic_id": "source_111111111111111111111111.Test.test_data2"
    }
  ],
  "sourceRecordWriteTotal": 547
}

topic_metrics

Topic Metrics · object

Show child attributes

topic_metrics.{key}

object

Show child attributes

topic_metrics.{key}.{key}

SourceBaseMetrics · object

Source base metrics.

Show child attributes

topic_metrics.{key}.{key}.timeseries

SourceTimeseriesMetrics · object

Source timeseries metrics.

Show child attributes

topic_metrics.{key}.{key}.timeseries.SnapshotMilliSecondsSinceLastEvent

TimeseriesEntry · object[]

Show child attributes

topic_metrics.{key}.{key}.timeseries.SnapshotMilliSecondsSinceLastEvent.value

required

topic_metrics.{key}.{key}.timeseries.SnapshotMilliSecondsSinceLastEvent.timestamp

string

required

topic_metrics.{key}.{key}.timeseries.SnapshotTotalNumberOfEventsSeen

TimeseriesEntry · object[]

Show child attributes

topic_metrics.{key}.{key}.timeseries.SnapshotTotalNumberOfEventsSeen.value

required

topic_metrics.{key}.{key}.timeseries.SnapshotTotalNumberOfEventsSeen.timestamp

string

required

topic_metrics.{key}.{key}.timeseries.StreamingMilliSecondsBehindSource

TimeseriesEntry · object[]

Show child attributes

topic_metrics.{key}.{key}.timeseries.StreamingMilliSecondsBehindSource.value

required

topic_metrics.{key}.{key}.timeseries.StreamingMilliSecondsBehindSource.timestamp

string

required

topic_metrics.{key}.{key}.timeseries.StreamingMilliSecondsSinceLastEvent

TimeseriesEntry · object[]

Show child attributes

topic_metrics.{key}.{key}.timeseries.StreamingMilliSecondsSinceLastEvent.value

required

topic_metrics.{key}.{key}.timeseries.StreamingMilliSecondsSinceLastEvent.timestamp

string

required

topic_metrics.{key}.{key}.timeseries.StreamingTotalNumberOfCreateEventsSeen

TimeseriesEntry · object[]

Show child attributes

topic_metrics.{key}.{key}.timeseries.StreamingTotalNumberOfCreateEventsSeen.value

required

topic_metrics.{key}.{key}.timeseries.StreamingTotalNumberOfCreateEventsSeen.timestamp

string

required

topic_metrics.{key}.{key}.timeseries.StreamingTotalNumberOfDeleteEventsSeen

TimeseriesEntry · object[]

Show child attributes

topic_metrics.{key}.{key}.timeseries.StreamingTotalNumberOfDeleteEventsSeen.value

required

topic_metrics.{key}.{key}.timeseries.StreamingTotalNumberOfDeleteEventsSeen.timestamp

string

required

topic_metrics.{key}.{key}.timeseries.recordSendTotal

TimeseriesEntry · object[]

Show child attributes

topic_metrics.{key}.{key}.timeseries.recordSendTotal.value

required

topic_metrics.{key}.{key}.timeseries.recordSendTotal.timestamp

string

required

topic_metrics.{key}.{key}.timeseries.StreamingTotalNumberOfUpdateEventsSeen

TimeseriesEntry · object[]

Show child attributes

topic_metrics.{key}.{key}.timeseries.StreamingTotalNumberOfUpdateEventsSeen.value

required

topic_metrics.{key}.{key}.timeseries.StreamingTotalNumberOfUpdateEventsSeen.timestamp

string

required

topic_metrics.{key}.{key}.timeseries.recordRetryTotal

TimeseriesEntry · object[]

Show child attributes

topic_metrics.{key}.{key}.timeseries.recordRetryTotal.value

required

topic_metrics.{key}.{key}.timeseries.recordRetryTotal.timestamp

string

required

topic_metrics.{key}.{key}.timeseries.recordWrittenTotal

TimeseriesEntry · object[]

Show child attributes

topic_metrics.{key}.{key}.timeseries.recordWrittenTotal.value

required

topic_metrics.{key}.{key}.timeseries.recordWrittenTotal.timestamp

string

required

topic_metrics.{key}.{key}.timeseries.byteTotal

TimeseriesEntry · object[]

Show child attributes

topic_metrics.{key}.{key}.timeseries.byteTotal.value

required

topic_metrics.{key}.{key}.timeseries.byteTotal.timestamp

string

required

topic_metrics.{key}.{key}.timeseries.sourceRecordWriteTotal

TimeseriesEntry · object[]

Show child attributes

topic_metrics.{key}.{key}.timeseries.sourceRecordWriteTotal.value

required

topic_metrics.{key}.{key}.timeseries.sourceRecordWriteTotal.timestamp

string

required

Example:

{
  "SnapshotMilliSecondsSinceLastEvent": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 500
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 300
    }
  ],
  "SnapshotTotalNumberOfEventsSeen": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 100
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 150
    }
  ],
  "StreamingMilliSecondsBehindSource": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 1000
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 800
    }
  ],
  "StreamingMilliSecondsSinceLastEvent": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 200
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 150
    }
  ],
  "StreamingTotalNumberOfCreateEventsSeen": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 20
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 35
    }
  ],
  "StreamingTotalNumberOfDeleteEventsSeen": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 5
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 8
    }
  ],
  "StreamingTotalNumberOfUpdateEventsSeen": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 30
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 45
    }
  ],
  "byteTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 10000
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 15000
    }
  ],
  "recordRetryTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 2
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 3
    }
  ],
  "recordSendTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 50
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 70
    }
  ],
  "recordWrittenTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 40
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 60
    }
  ],
  "sourceRecordWriteTotal": [
    {
      "timestamp": "2025-03-02 08:00:00",
      "value": 25
    },
    {
      "timestamp": "2025-03-02 09:00:00",
      "value": 40
    }
  ]
}

topic_metrics.{key}.{key}.latest

SourceLatestMetrics · object

Source latest metrics.

Show child attributes

topic_metrics.{key}.{key}.latest.SnapshotTotalNumberOfEventsSeen

topic_metrics.{key}.{key}.latest.SnapshotMilliSecondsSinceLastEvent

topic_metrics.{key}.{key}.latest.StreamingMilliSecondsBehindSource

topic_metrics.{key}.{key}.latest.StreamingTotalNumberOfDeleteEventsSeen

topic_metrics.{key}.{key}.latest.StreamingTotalNumberOfUpdateEventsSeen

topic_metrics.{key}.{key}.latest.StreamingTotalNumberOfCreateEventsSeen

topic_metrics.{key}.{key}.latest.StreamingMilliSecondsSinceLastEvent

topic_metrics.{key}.{key}.latest.StreamingLastEvent

string | null

topic_metrics.{key}.{key}.latest.recordRetryTotal

topic_metrics.{key}.{key}.latest.byteTotal

topic_metrics.{key}.{key}.latest.sourceRecordWriteTotal

topic_metrics.{key}.{key}.latest.SnapshotRunning

topic_metrics.{key}.{key}.latest.SnapshotCompleted

topic_metrics.{key}.{key}.latest.StreamingConnected

topic_metrics.{key}.{key}.latest.recordSendTotal

topic_metrics.{key}.{key}.latest.state

string | null

topic_metrics.{key}.{key}.latest.streamingState

string | null

topic_metrics.{key}.{key}.latest.snapshotStatus

Snapshotstatus · object[] | null

Show child attributes

topic_metrics.{key}.{key}.latest.snapshotStatus.{key}

topic_metrics.{key}.{key}.latest.snapshotState

string | null

topic_metrics.{key}.{key}.latest.recordWrittenTotal

topic_metrics.{key}.{key}.latest.connector_status

string | null

topic_metrics.{key}.{key}.latest.latency

Example:

{
  "SnapshotCompleted": 2,
  "SnapshotMilliSecondsSinceLastEvent": 3600000,
  "SnapshotRunning": 0,
  "SnapshotTotalNumberOfEventsSeen": 20254,
  "StreamingConnected": 1,
  "StreamingLastEvent": "position: {ord: 14}, key: {\"id\" : \"\"ceaafb88-2a60-4bd9-8515-719ba64ea05c-close\"\"}",
  "StreamingMilliSecondsBehindSource": 500,
  "StreamingMilliSecondsSinceLastEvent": 200,
  "StreamingTotalNumberOfCreateEventsSeen": 73,
  "StreamingTotalNumberOfDeleteEventsSeen": 312,
  "StreamingTotalNumberOfUpdateEventsSeen": 0,
  "byteTotal": 9018776,
  "connector_status": "Active",
  "latency": 150,
  "recordRetryTotal": 10,
  "recordSendTotal": 400,
  "recordWrittenTotal": 395,
  "snapshotState": "completed",
  "snapshotStatus": [
    {
      "status": "completed",
      "submit_timestamp": "2023-10-01T10:00:00Z",
      "topic_id": "source_111111111111111111111111.Test.test_data1"
    },
    {
      "status": "completed",
      "submit_timestamp": "2023-10-01T10:10:00Z",
      "topic_id": "source_111111111111111111111111.Test.test_data2"
    }
  ],
  "sourceRecordWriteTotal": 27785,
  "state": "Streaming",
  "streamingState": "connected"
}

topic_metrics.{key}.{key}.timesummary

SourceTimesummaryMetrics · object

Source timesummary metrics.

Show child attributes

topic_metrics.{key}.{key}.timesummary.SnapshotTotalNumberOfEventsSeen

topic_metrics.{key}.{key}.timesummary.SnapshotMilliSecondsSinceLastEvent

topic_metrics.{key}.{key}.timesummary.StreamingMilliSecondsBehindSource

topic_metrics.{key}.{key}.timesummary.StreamingTotalNumberOfDeleteEventsSeen

topic_metrics.{key}.{key}.timesummary.StreamingTotalNumberOfUpdateEventsSeen

topic_metrics.{key}.{key}.timesummary.StreamingTotalNumberOfCreateEventsSeen

topic_metrics.{key}.{key}.timesummary.StreamingMilliSecondsSinceLastEvent

topic_metrics.{key}.{key}.timesummary.recordRetryTotal

topic_metrics.{key}.{key}.timesummary.recordSendTotal

topic_metrics.{key}.{key}.timesummary.recordWrittenTotal

topic_metrics.{key}.{key}.timesummary.byteTotal

topic_metrics.{key}.{key}.timesummary.sourceRecordWriteTotal

topic_metrics.{key}.{key}.timesummary.snapshotStatus

Snapshotstatus · object[] | null

Show child attributes

topic_metrics.{key}.{key}.timesummary.snapshotStatus.{key}

topic_metrics.{key}.{key}.timesummary.snapshotState

string | null

topic_metrics.{key}.{key}.timesummary.connector_status

string | null

topic_metrics.{key}.{key}.timesummary.latency

Example:

{
  "SnapshotMilliSecondsSinceLastEvent": 500,
  "SnapshotTotalNumberOfEventsSeen": 65,
  "StreamingMilliSecondsBehindSource": 200,
  "StreamingMilliSecondsSinceLastEvent": 100,
  "StreamingTotalNumberOfCreateEventsSeen": 20,
  "StreamingTotalNumberOfDeleteEventsSeen": 13,
  "StreamingTotalNumberOfUpdateEventsSeen": 25,
  "byteTotal": 6000,
  "connector_status": "Active",
  "latency": 100,
  "recordRetryTotal": 5,
  "recordSendTotal": 60,
  "recordWrittenTotal": 58,
  "snapshotState": "completed",
  "snapshotStatus": [
    {
      "status": "completed",
      "submit_timestamp": "2023-10-01T12:00:00Z",
      "topic_id": "source_111111111111111111111111.Test.test_data1"
    },
    {
      "status": "completed",
      "submit_timestamp": "2023-10-01T12:05:00Z",
      "topic_id": "source_111111111111111111111111.Test.test_data2"
    }
  ],
  "sourceRecordWriteTotal": 547
}

Streamkap REST API

Authorizations

Query Parameters

Response