Lukas Kucharski created NIFI-15576:
--------------------------------------
Summary: ConsumeKinesis processor should log lag in milliseconds
Key: NIFI-15576
URL: https://issues.apache.org/jira/browse/NIFI-15576
Project: Apache NiFi
Issue Type: Improvement
Components: Extensions
Reporter: Lukas Kucharski
Assignee: Lukas Kucharski
The *ConsumeKinesis* processor should use
{code:java}
ProcessSession#recordGuage{code}
to record a lag in milliseconds for shards being processed.
The lag value will be fetched from KCL's
{code:java}
ProcessRecordInput#millisBehindLatest
{code}
field
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
