@connectum/events-kafka

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

Install

npm install @connectum/events-kafka

pnpm add @connectum/events-kafka

bun add @connectum/events-kafka

Start Here

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

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

For a complete, source-verified workflow, continue with the focused guide below.

Key Entry Points

Entry point	Use it to
KafkaAdapter	Connect EventBus to Kafka or Redpanda.
KafkaAdapterOptions	Configure brokers, client, producer, and consumer behavior.

Runtime boundaries and extension seams remain in Connectum Runtime Architecture.

Learn / Configure / API Reference

• Learn: Focused guide
• Configure: Task and configuration guidance
• API reference: Exact options and symbols
• Package API index: Generated TypeDoc
• Source: @connectum/events-kafka on GitHub

Related Modules

Compare all Connectum packages by capability.