MCPcopy
hub / github.com/IBM/sarama / NextOffset

Method NextOffset

offset_manager.go:517–517  ·  view source on GitHub ↗

NextOffset returns the next offset that should be consumed for the managed partition, accompanied by metadata which can be used to reconstruct the state of the partition consumer when it resumes. NextOffset() will return `config.Consumer.Offsets.Initial` and an empty metadata string if no offset was

()

Source from the content-addressed store, hash-verified

515 // `config.Consumer.Offsets.Initial` and an empty metadata string if no offset
516 // was committed for this partition yet.
517 NextOffset() (int64, string)
518
519 // MarkOffset marks the provided offset, alongside a metadata string
520 // that represents the state of the partition consumer at that point in time. The

Implementers 1

partitionOffsetManageroffset_manager.go

Calls

no outgoing calls