Interface EachBatchPayload
Methods
commitOffsetsIfNecessary
- commitOffsetsIfNecessary(offsets?: Offsets): Promise<void>
- commitOffsetsIfNecessary(offsets?: Offsets): Promise<void>
-
Parameters
Returns Promise<void>
-
Parameters
-
Optional offsets: Offsets
Returns Promise<void>
heartbeat
- heartbeat(): Promise<void>
- heartbeat(): Promise<void>
-
Returns Promise<void>
-
Returns Promise<void>
isRunning
- isRunning(): boolean
- isRunning(): boolean
-
Returns boolean
-
Returns boolean
isStale
- isStale(): boolean
- isStale(): boolean
-
Returns boolean
-
Returns boolean
resolveOffset
- resolveOffset(offset: string): void
- resolveOffset(offset: string): void
-
Parameters
Returns void
-
Parameters
Returns void
uncommittedOffsets
-
-
Returns Promise<OffsetsByTopicPartition>