Skip to content

Latest commit

 

History

History
77 lines (59 loc) · 1.2 KB

kafka-common-record-Records.adoc

File metadata and controls

77 lines (59 loc) · 1.2 KB
Raw

Records

Records is the extension of the BaseRecords contract for FIXME that FIXME.

Table 1. Records Contract
Method Description

batches

 
Iterable<? extends RecordBatch> batches()

batchIterator

 
AbstractIterator<? extends RecordBatch> batchIterator()

downConvert

 
ConvertedRecords<? extends Records> downConvert(
  byte toMagic,
  long firstOffset,
  Time time)

hasCompatibleMagic

 
boolean hasCompatibleMagic(byte magic)

hasMatchingMagic

 
boolean hasMatchingMagic(byte magic)

records

 
Iterable<Record> records()

writeTo

 
long writeTo(
  GatheringByteChannel channel,
  long position,
  int length) throws IOException
Note
 AbstractRecords is the default and only known Records extension in Apache Kafka.