Skip to main content
Deno 2 is finally here 🎉️
Learn more
Latest
class SubscriptionState
import { SubscriptionState } from "https://deno.land/x/kafkasaur@v0.0.7/src/consumer/subscriptionState.ts";

Constructors

new
SubscriptionState()

Properties

assignedPartitionsByTopic: any
subscriptionStatesByTopic: any

Methods

assign(topicPartitions?: any[])

Replace the current assignment with a new set of assignments

isPaused(topic: any, partition: any)
pause(topicPartitions?)
resume(topicPartitions?)