XMLWordPrintableJSON

Details

    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

          Activity

            People

              lucasbru Lucas Brutschy
              pnee Philip Nee
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: