kafkatsPure TypeScript Kafka Client

High-performance Kafka client and streams library with zero native dependencies

⚡

Pure Protocol Implementation

No wrappers around librdkafka. Direct Kafka wire protocol implementation in TypeScript for maximum control and transparency.

🌊

Kafka Streams-like DSL

Familiar APIs for stream processing with KStream, KTable, windowing, aggregations, and joins.

🔒

Type-Safe Codecs

Strong typing from producer to consumer with built-in codecs and Zod validation support.

🎯

Exactly-Once Semantics

Full transactional support for idempotent producers and exactly-once processing guarantees.

💾

Pluggable State Stores

In-memory and LMDB backends for stateful stream processing with windowed aggregations.

🚀

Modern TypeScript

ESM-first, async/await, full TypeScript support with comprehensive types and tree-shaking.

Packages

@kafkats/client

Core Kafka client with producer, consumer, SASL authentication, and low-level protocol access.

@kafkats/flow

Kafka Streams-like DSL with KStream, KTable, windowing, aggregations, and joins.

@kafkats/flow-codec-zod

Zod schema validation for type-safe message encoding and decoding.

@kafkats/flow-state-lmdb

LMDB-backed persistent state stores for production stream processing.

Quick Example

typescript

import { KafkaClient } from '@kafkats/client'

const client = new KafkaClient({
	clientId: 'my-app',
	brokers: ['localhost:9092'],
})

// Producer
const producer = client.producer()
await producer.send('events', [{ value: JSON.stringify({ type: 'click', page: '/home' }) }])

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