MCPcopy
hub / github.com/segmentio/kafka-go / ReadRecord

Method ReadRecord

protocol/record_batch.go:21–21  ·  view source on GitHub ↗

Returns the next record in the set, or io.EOF if the end of the sequence has been reached. The returned Record is guaranteed to be valid until the next call to ReadRecord. If the program needs to retain the Record value it must make a copy.

()

Source from the content-addressed store, hash-verified

19 // ReadRecord. If the program needs to retain the Record value it must make
20 // a copy.
21 ReadRecord() (*Record, error)
22}
23
24// NewRecordReader constructs a reader exposing the records passed as arguments.

Callers 13

readRecordsFunction · 0.65
TestClientPipelineFunction · 0.65
assertRecordsFunction · 0.65
forEachRecordFunction · 0.65
ReadRecordMethod · 0.65
ReadRecordMethod · 0.65
ReadRecordMethod · 0.65
ReadRecordMethod · 0.65
ReadRecordMethod · 0.65
closeMessageFunction · 0.65
loadRecordsFunction · 0.65

Implementers 10

writerRecordswriter.go
messageprotocol/record_v1.go
recordReaderprotocol/record_batch.go
multiRecordReaderprotocol/record_batch.go
optimizedRecordReaderprotocol/record_batch.go
emptyRecordReaderprotocol/record_batch.go
ControlBatchprotocol/record_batch.go
RecordBatchprotocol/record_batch.go
MessageSetprotocol/record_batch.go
RecordStreamprotocol/record_batch.go

Calls

no outgoing calls

Tested by 4

readRecordsFunction · 0.52
TestClientPipelineFunction · 0.52
assertRecordsFunction · 0.52