[jira] [Created] (KAFKA-15803) Update last seen epcoh during commit

[Philip Nee (Jira)]

Philip Nee created KAFKA-15803:
----------------------------------

             Summary: Update last seen epcoh during commit
                 Key: KAFKA-15803
                 URL: https://issues.apache.org/jira/browse/KAFKA-15803
             Project: Kafka
          Issue Type: Task
            Reporter: Philip Nee
            Assignee: Philip Nee


At the time we implemented commitAsync in the prototypeAsyncConsumer, metadata 
was not there. The ask here is to investigate if we need to add the following 
function to the commit code:

 

private void updateLastSeenEpochIfNewer(TopicPartition topicPartition, 
OffsetAndMetadata offsetAndMetadata) {
if (offsetAndMetadata != null)
offsetAndMetadata.leaderEpoch().ifPresent(epoch -> 
metadata.updateLastSeenEpochIfNewer(topicPartition, epoch));
}



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