MCPcopy Create free account
hub / github.com/IBM/sarama / AddBlock

Method AddBlock

offset_commit_request.go:307–309  ·  view source on GitHub ↗
(topic string, partitionID int32, offset int64, timestamp int64, metadata string)

Source from the content-addressed store, hash-verified

305}
306
307func (r *OffsetCommitRequest) AddBlock(topic string, partitionID int32, offset int64, timestamp int64, metadata string) {
308 r.AddBlockWithLeaderEpoch(topic, partitionID, offset, 0, timestamp, metadata)
309}
310
311func (r *OffsetCommitRequest) AddBlockWithLeaderEpoch(topic string, partitionID int32, offset int64, leaderEpoch int32, timestamp int64, metadata string) {
312 if r.blocks == nil {

Callers

nothing calls this directly

Calls 1

Tested by

no test coverage detected