@osskit/dafka-producer-fetch-client

typescript-fetch client wrapper for dafka-producer

Install

yarn add @osskit/dafka-producer-fetch-client

Usage

Scoped

import { createProducer } from '@osskit/dafka-producer-fetch-client'

export const produce = createProducer<TEventData>('https://my-dafka-producer-url', 'my-topic', 'my-partition-key');

await produce<TEventData>(payload);

API

createProducer(url: string, topic: string, key?: string)

url

Type: string

The URL of dafka-producer

topic

Type: string

The Kafka Topic name

key

Type: string

The Kafka Topic Partition key, if not supplied then a random UUID is generated

returns

An instance of a function that receives <T>(payload: T)

License

MIT License