Details
-
Sub-task
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
Description
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)); }Attachments
Issue Links
- links to