Interface FetchablePartitionResponse

Hierarchy

  • FetchablePartitionResponse

Properties

aborted?: ArrayBuffer
errorCode: ErrorCode
highWatermark: number
lastStableOffset: number
logStartOffset: number
partitionIndex: number
records: RecordSet

Methods

  • toRecords(): string[]
  • let response = await this.fluvioConsumer.fetch(Offset.FromStart())
    response.toRecords().forEach(msg => {
    console.log(msg)
    })

    Returns string[]

Generated using TypeDoc