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

Method SetLastStableOffset

fetch_response.go:745–748  ·  view source on GitHub ↗
(topic string, partition int32, offset int64)

Source from the content-addressed store, hash-verified

743}
744
745func (r *FetchResponse) SetLastStableOffset(topic string, partition int32, offset int64) {
746 frb := r.getOrCreateBlock(topic, partition)
747 frb.LastStableOffset = offset
748}

Callers 3

TestConsumerExtraOffsetsFunction · 0.95
TestConsumerNonSequentialOffsetsFunction · 0.95
TestConsumerTimestampsFunction · 0.95

Calls 1

getOrCreateBlockMethod · 0.95

Tested by 3

TestConsumerExtraOffsetsFunction · 0.76
TestConsumerNonSequentialOffsetsFunction · 0.76
TestConsumerTimestampsFunction · 0.76