Lukas Kucharski created NIFI-15563:
--------------------------------------
Summary: Report LAG in records from ConsumeKafka processor
Key: NIFI-15563
URL: https://issues.apache.org/jira/browse/NIFI-15563
Project: Apache NiFi
Issue Type: Improvement
Components: Extensions
Reporter: Lukas Kucharski
Assignee: Lukas Kucharski
We want to report LAG metrics from the ConsumeKafka processor. For this
recently added `KafkaConsumerService#currentLag(TopicPartitionSummary)` needs
to be used ( https://issues.apache.org/jira/browse/NIFI-15545) The LAG returned
by the method will be sent as the telemetry using ProcessSession#repocordGauge
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
