OffsetManager | /src/consumer/offsetManager/index.ts | kafkasaur@v0.0.7

class OffsetManager

import { OffsetManager } from "https://deno.land/x/kafkasaur@v0.0.7/src/consumer/offsetManager/index.ts";

Constructors

new

OffsetManager(unnamed 0: any)

[key: string]: any

autoCommit: any

autoCommitInterval: any

autoCommitThreshold: any

cluster: any

coordinator: any

generationId: any

groupId: any

instrumentationEmitter: any

lastCommit: any

memberAssignment: any

memberId: any

resolvedOffsets: any

topicConfigurations: any

topics: any

clearOffsets(unnamed 0: any)

commitOffsets(offsets?: { [key: string]: any; })

nextOffset(topic: any, partition: any)

resetOffset(unnamed 0: any)

resolveOffset(unnamed 0: any)

seek(unnamed 0: any)

Commit the given offset to the topic/partition. If the consumer isn't assigned to the given topic/partition this method will be a NO-OP.

Return all locally resolved offsets which are not marked as committed, by topic-partition.