Appearance

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

Function: KafkaAdapter() ​

KafkaAdapter(options): EventAdapter

Defined in: KafkaAdapter.ts:122

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

Parameters ​

options ​

KafkaAdapterOptions

Kafka adapter configuration

Returns ​

EventAdapter

EventAdapter instance

Example ​

typescript
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();