Skip to main content
Module

x/kafkagosaur/writer.ts>KafkaWriter

Kafka client for Deno binding to kafka-go using WebAssembly
arjun-1/kafkagosaur
Latest
interface KafkaWriter
import { type KafkaWriter } from "https://deno.land/x/kafkagosaur@v0.0.6/writer.ts";

Properties

writeMessages: (msgs: KafkaWriteMessage[]) => Promise<void>

Writes a batch of messages to the configured kafka topic.

close: () => Promise<void>

Close flushes pending writes, and waits for all writes to complete before returning.

stats: () => string

Stats returns a snapshot of the writer stats since the last time the method was called, or since the writer was created if it is called for the first time.