(topic string, partitionID int32, offset int64, timestamp int64, metadata string)
| 305 | } |
| 306 | |
| 307 | func (r *OffsetCommitRequest) AddBlock(topic string, partitionID int32, offset int64, timestamp int64, metadata string) { |
| 308 | r.AddBlockWithLeaderEpoch(topic, partitionID, offset, 0, timestamp, metadata) |
| 309 | } |
| 310 | |
| 311 | func (r *OffsetCommitRequest) AddBlockWithLeaderEpoch(topic string, partitionID int32, offset int64, leaderEpoch int32, timestamp int64, metadata string) { |
| 312 | if r.blocks == nil { |
nothing calls this directly
no test coverage detected