Description

OffsetNewest stands for the log head offset, i.e. the offset that will be assigned to the next message that will be produced to the partition. You can send this to a client's GetOffset method to get this offset, or when calling ConsumePartition to start consuming new messages.

OffsetNewest is referenced in 41 repositories

github.com/Shopify/sarama github.com/funkygao/gafka github.com/bsm/sarama-cluster

...