@kafkats/client

A pure-protocol TypeScript Kafka client with producer, consumer, and admin APIs.

Features

• Pure TypeScript — Direct protocol implementation, not a wrapper
• Producer — Batching, compression (gzip, snappy, lz4, zstd), custom partitioners
• Consumer — Consumer groups, partition assignment, offset management
• ShareConsumer (experimental) — Share Groups (KIP-932) with per-record acknowledgements
• Admin — Topic management, consumer groups, cluster metadata
• SASL Auth — PLAIN, SCRAM-SHA-256, SCRAM-SHA-512
• Typed Codecs — Built-in string, JSON, and buffer codecs

Installation

npm install @kafkats/client

Usage

import { KafkaClient } from '@kafkats/client'

const client = new KafkaClient({ brokers: ['localhost:9092'] })

// Producer
const producer = client.producer()
await producer.connect()
await producer.send('events', [{ key: 'user-1', value: 'hello' }])

// Consumer
const consumer = client.consumer({ groupId: 'my-group' })
await consumer.runEach('events', async (message, ctx) => {
	console.log(message.value?.toString())
})

// ShareConsumer (experimental)
const shareConsumer = client.shareConsumer({ groupId: 'my-share-group' })
await shareConsumer.runEach('events', async message => {
	console.log(message.value?.toString())
	// If you don't call ack/release/reject, the message is implicitly ack'd (ACCEPT) on success.
})

// Admin
const admin = client.admin()
await admin.connect()
await admin.createTopics([{ name: 'events', partitions: 3 }])

Documentation

Full documentation at chrisrecalis.github.io/kafkats

License

MIT