(topic string, partition int32, key, value Encoder, offset int64, producerID int64, isTransactional bool)
| 726 | } |
| 727 | |
| 728 | func (r *FetchResponse) AddRecordBatch(topic string, partition int32, key, value Encoder, offset int64, producerID int64, isTransactional bool) { |
| 729 | r.AddRecordBatchWithTimestamp(topic, partition, key, value, offset, producerID, isTransactional, time.Time{}) |
| 730 | } |
| 731 | |
| 732 | func (r *FetchResponse) AddControlRecord(topic string, partition int32, offset int64, producerID int64, recordType ControlRecordType) { |
| 733 | // define controlRecord key and value |