Skip to main content
Deno 2 is finally here 🎉️
Learn more
Module

x/kafkasaur/src/consumer/consumerGroup.ts>ConsumerGroup

A Kafka Client for Deno!
KafkaSaur/kafkaSaur
Latest
class ConsumerGroup
import { ConsumerGroup } from "https://deno.land/x/kafkasaur@v0.0.7/src/consumer/consumerGroup.ts";

Constructors

new
ConsumerGroup(unnamed 0: ConsumerGroupOptions)

Index Signatures

[index: string]: any

Properties

assigners: Assigner[]
autoCommit: boolean
autoCommitInterval: number | null
autoCommitThreshold: number | null
cluster: Cluster
coordinator: Broker | null
generationId: number | null
groupId: string
groupProtocol: string | null
instrumentationEmitter: any
isolationLevel: number
lastRequest: number
leaderId: string | null
logger: Logger
maxBytes: number
maxBytesPerPartition: number
maxWaitTime: number
maxWaitTimeInMs: any
memberId: string | null
members: GroupMember[] | null
metadataMaxAge: number
minBytes: number
offsetManager: OffsetManager | null
partitionsPerSubscribedTopic: Map<any, any> | null
preferredReadReplicasPerTopicPartition: any
rackId: string
rebalanceTimeout: number
retrier: any
seekOffset: SeekOffsets
sessionTimeout: number
subscriptionState: SubscriptionState | null
topicConfigurations: { [topic: string]: { fromBeginning: boolean; }; }
topics: string[]
topicsSubscribed: string[]

Methods

commitOffsets(offsets: any)
findReadReplicaForPartitions(topic: any, partitions: any)

For each of the partitions find the best nodeId to read it from

hasSeekOffset(unnamed 0: any)
heartbeat(unnamed 0: any)
pause(topicPartitions: any)
resetOffset(unnamed 0: any)
resolveOffset(unnamed 0: any)
resume(topicPartitions: any)
seek(unnamed 0: any)

Update the consumer offset for the given topic/partition. This will be used on the next fetch. If this API is invoked for the same topic/partition more than once, the latest offset will be used on the next fetch.

[PRIVATE.JOIN]()
[PRIVATE.SYNC]()