RecordBatch is an implementation of the RecordReader interface representing regular record batches (v2).
| 285 | // RecordBatch is an implementation of the RecordReader interface representing |
| 286 | // regular record batches (v2). |
| 287 | type RecordBatch struct { |
| 288 | Attributes Attributes |
| 289 | PartitionLeaderEpoch int32 |
| 290 | BaseOffset int64 |
| 291 | ProducerID int64 |
| 292 | ProducerEpoch int16 |
| 293 | BaseSequence int32 |
| 294 | Records RecordReader |
| 295 | } |
| 296 | |
| 297 | func (r *RecordBatch) ReadRecord() (*Record, error) { |
| 298 | return r.Records.ReadRecord() |
nothing calls this directly
no outgoing calls
no test coverage detected