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.

results matching ""

    No results matching ""