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

Method ReadRecord

protocol/record_batch.go:259–261  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

257}
258
259func (c *ControlBatch) ReadRecord() (*Record, error) {
260 return c.Records.ReadRecord()
261}
262
263func (c *ControlBatch) ReadControlRecord() (*ControlRecord, error) {
264 r, err := c.ReadRecord()

Callers 1

ReadControlRecordMethod · 0.95

Calls 1

ReadRecordMethod · 0.65

Tested by

no test coverage detected