(topic string, partition int32, offset int64, producerID int64, recordType ControlRecordType)
| 730 | } |
| 731 | |
| 732 | func (r *FetchResponse) AddControlRecord(topic string, partition int32, offset int64, producerID int64, recordType ControlRecordType) { |
| 733 | // define controlRecord key and value |
| 734 | r.AddControlRecordWithTimestamp(topic, partition, offset, producerID, recordType, time.Time{}) |
| 735 | } |
| 736 | |
| 737 | func (r *FetchResponse) SetLastOffsetDelta(topic string, partition int32, offset int32) { |
| 738 | frb := r.getOrCreateBlock(topic, partition) |