[jira] [Created] (NIFI-15545) Extend KafkaConsumerService.getPartitionStates() to return lag information

[Lukas Kucharski (Jira)]

Lukas Kucharski created NIFI-15545:
--------------------------------------

             Summary: Extend KafkaConsumerService.getPartitionStates() to 
return lag information
                 Key: NIFI-15545
                 URL: https://issues.apache.org/jira/browse/NIFI-15545
             Project: Apache NiFi
          Issue Type: New Feature
          Components: Extensions
            Reporter: Lukas Kucharski
            Assignee: Lukas Kucharski


We want to report lag-related metrics from the 
{code:java}
org.apache.nifi.kafka.processors.ConsumeKafka
{code}
To do this, we will modify
{code:java}
org.apache.nifi.kafka.service.api.consumer.KafkaConsumerService#getPartitionStates()
{code}
to return additional information obtained from the KafkaConsumer implementation 
(currentLag). 
 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)