Module

x/kafkasaur/src/cluster/index.ts>Cluster

A Kafka Client for Deno!
KafkaSaur/kafkaSaur
Latest
class Cluster
import { Cluster } from "https://dotland.deno.dev/x/kafkasaur@v0.0.7/src/cluster/index.ts";

Constructors

new
Cluster(unnamed 0: any)

Properties

brokerPool: any
committedOffsetsByGroup: any
connectionBuilder: any
isolationLevel: number
logger: Logger
mutatingTargetTopics: any
retrier: any
rootLogger: Logger
targetTopics: Set<string>

Methods

addTargetTopic(topic: any)
committedOffsets(unnamed 0: any)

Retrieve the object mapping for committed offsets for a single consumer group

defaultOffset(unnamed 0: any)
fetchTopicsOffset(topics: any)
findBroker(unnamed 0: any)
findGroupCoordinator(unnamed 0: any)
findLeaderForPartitions(topic: any, partitions: any)
markOffsetAsCommitted(unnamed 0: any)

Mark offset as committed for a single consumer group's topic-partition

metadata(unnamed 0?)
removeBroker(unnamed 0: any)