Package io.confluent.parallelconsumer.internal

Interface OffsetCommitter

All Known Implementing Classes:
AbstractOffsetCommitter, BrokerPollSystem, ConsumerOffsetCommitter, ProducerManager
public interface OffsetCommitter

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    retrieveOffsetsAndCommit()
     

  • Method Details

    • retrieveOffsetsAndCommit

      void retrieveOffsetsAndCommit()