Skip to content
PackagesCommunicationDocs 1.3.x

@connectum/events-kafka ​

Kafka and Redpanda adapter with consumer groups, topic patterns, and message headers.

Install ​

bash
npm install @connectum/events-kafka
bash
pnpm add @connectum/events-kafka
bash
bun add @connectum/events-kafka

Start Here ​

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

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

Key Entry Points ​

Entry pointUse it to
KafkaAdapterConnect EventBus to Kafka or Redpanda.
KafkaAdapterOptionsConfigure brokers, client, producer, and consumer behavior.

Learn / Configure / API Reference ​

Compare all Connectum packages by capability.