Pure-protocol Kafka client, consumer/producer, and EOS patterns in TypeScript.
npm install @kafkats/clientA pure-protocol TypeScript Kafka client with producer, consumer, and admin APIs.
- 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
``bash`
npm install @kafkats/client
`typescript
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 }])
``
Full documentation at chrisrecalis.github.io/kafkats
MIT