...
Name | Type | Unit | Description |
numBytesIn | Counter | Bytes | The total number of input bytes since the source started |
numBytesInPerSec | Meter | Bytes/Sec | The input bytes per second |
numRecordsIn | Counter | Records | The total number of input records since the source started |
numRecordsInPerSec | Meter | Records/Sec | The input records per second |
numErrorRecordsInnumRecordsInErrors | Counter | Records | The total number of record that failed to consume |
recordSize | Histogram | Bytes | The size of a record |
fetchLatency | Histogram | ms | The latency occurred before Flink fetched the record. fetchLatency = FetchTime - EventTime |
latency | Histogram | ms | The latency occurred before the record is emitted by the source connector. latency = EmitTime - EventTime |
idleTime | Gauge | ms | The time in milliseconds that the source has not processed any record. idleTime = CurrentTime - LastRecordProcessTime |
...
Name | Type | Unit | Description |
numBytesOut | Counter | Bytes | The total number of output bytes since the source started |
numBytesOutPerSec | Meter | Bytes/Sec | The output bytes per second |
numRecordsOut | Counter | Records | The total number of output records since the source started |
numRecordsOutPerSec | Meter | Records/Sec | The output records per second |
numErrorRecordsOutnumRecordsOutErrors | Counter | Record | The total number of records failed to send |
recordSize | Histogram | Bytes | The size of a record |
sendTime | Histogram | ms | The time it takes to send a record |
...