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

x/kafkasaur/src/consumer/index.ts>default

A Kafka Client for Deno!
Latest
variable default
import { default } from "https://deno.land/x/kafkasaur@v0.0.7/src/consumer/index.ts";

type

(unnamed 0: { cluster: any; groupId: string | undefined; retry: any; logger: Logger; partitionAssigners: PartitionAssigner[] | undefined; sessionTimeout: number | undefined; rebalanceTimeout: number | undefined; heartbeatInterval: number | undefined; maxBytesPerPartition: number | undefined; minBytes: number | undefined; maxBytes: number | undefined; maxWaitTimeInMs: number | undefined; isolationLevel: any; rackId: string; instrumentationEmitter: any; metadataMaxAge: number; }) => unknown