Connectum API Reference / @connectum/events-kafka / KafkaAdapter

Function: KafkaAdapter()

KafkaAdapter(options): EventAdapter

Defined in: KafkaAdapter.ts:101

Create a Kafka/Redpanda adapter for @connectum/events.

Parameters

options

KafkaAdapterOptions

Kafka adapter configuration

Returns

EventAdapter

EventAdapter instance

Example

import { KafkaAdapter } from "@connectum/events-kafka";

const adapter = KafkaAdapter({
    brokers: ["localhost:9092"],
    clientId: "my-service",
});

await adapter.connect();
await adapter.publish("user.created", payload);
await adapter.disconnect();