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

x/kafkagosaur/deps.ts

Kafka client for Deno binding to kafka-go using WebAssembly
Latest
import * as kafkagosaur from "https://deno.land/x/kafkagosaur@v0.0.6/deps.ts";

Classes

This class is an abstraction of a TCP socket or a streaming IPC endpoint (uses named pipes on Windows, and Unix domain sockets otherwise). It is also an EventEmitter.

Functions

Create a promise which will be rejected with DeadlineError when a given delay is exceeded.

Creates a Promise with the reject and resolve functions placed as methods on the promise object itself. It allows you to do: