import { default } from "https://deno.land/x/kafkasaur@v0.0.7/src/cluster/brokerPool.ts";
Constructors
new
default(unnamed 0: { connectionBuilder: any; logger: Logger; retry: RetryOptions; allowAutoTopicCreation: boolean; authenticationTimeout: number; reauthenticationThreshold: number; metadataMaxAge: number; })Properties
createBroker: (options: any) => Broker
logger: Logger
metadata: BrokerMetadata | null
rootLogger: Logger
seedBroker: Broker | undefined
versions: ApiVersions | null
Methods
connect()
connectBroker(broker: any)
findBroker(unnamed 0: any)
refreshMetadata(topics: string[])
refreshMetadataIfNecessary(topics: string[])
Only refreshes metadata if the data is stale according to the metadataMaxAge param or does not contain information about the provided topics
removeBroker(unnamed 0: { host: string; port: number; })
withBroker(callback: any)