dariuszseweryn commented on code in PR #10881:
URL: https://github.com/apache/nifi/pull/10881#discussion_r2872039015
##########
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-kinesis/src/main/resources/docs/org.apache.nifi.processors.aws.kinesis.ConsumeKinesis/additionalDetails.md:
##########
@@ -283,3 +283,12 @@ Here is an example of FlowFile content that is emitted by
JsonRecordSetWriter wh
}
]
```
+
+## Metrics
+
+_ConsumeKinesis_ reports the following metrics:
+
+| Name | Type
| Description
|
+|----------------------------------------------------------------------|---------|------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
+| `aws.kinesis.current.lag[stream.name="<stream>",shard.id="<shard>"]` | Gauge
| The number of milliseconds the consumer is behind the tip of the shard, as
reported by the Kinesis Client Library. There is one gauge per stream/shard
combination. The gauge is updated each time a batch of records is successfully
processed and the session is committed. A value of `0` means the consumer is
caught up. |
Review Comment:
I've added a mention
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
