Options
All
  • Public
  • Public/Protected
  • All
Menu

Interface DecodedEachBatchPayload<TValue, TKey>

A payload for eachBatch where each message has been decoded with kafkajs SchemaRegistry

Type parameters

  • TValue

    The decodeed type of the the kafka message value

  • TKey

Hierarchy

  • EachBatchPayload
    • DecodedEachBatchPayload

Index

Properties

batch: DecodedBatch<TValue, TKey>
schemaRegistry: default

Methods

  • commitOffsetsIfNecessary(offsets?: Offsets): Promise<void>
  • Parameters

    • Optional offsets: Offsets

    Returns Promise<void>

  • heartbeat(): Promise<void>
  • Returns Promise<void>

  • isRunning(): boolean
  • Returns boolean

  • isStale(): boolean
  • Returns boolean

  • resolveOffset(offset: string): void
  • Parameters

    • offset: string

    Returns void

  • uncommittedOffsets(): OffsetsByTopicPartition
  • Returns OffsetsByTopicPartition

Generated using TypeDoc