Options
All
  • Public
  • Public/Protected
  • All
Menu

Hierarchy

  • FetchablePartitionResponse

Index

Properties

Optional aborted

aborted: undefined | ArrayBuffer

errorCode

errorCode: ErrorCode

highWatermark

highWatermark: number

lastStableOffset

lastStableOffset: number

logStartOffset

logStartOffset: number

partitionIndex

partitionIndex: number

records

records: RecordSet

Methods

toRecords

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

    Returns string[]

Legend

  • Constructor
  • Property
  • Method
  • Property
  • Method
  • Private property
  • Private method
  • Static method

Generated using TypeDoc