Loop Engine™

Packages

Adapter Kafka

@loop-engine/adapter-kafka

Kafka-backed EventBus adapter.

Install

1npm install @loop-engine/adapter-kafka kafkajs

API reference

kafkaEventBus

1kafkaEventBus(options: {
2  kafka: {
3    producer(): ProducerLike
4    consumer(args: { groupId: string }): ConsumerLike
5  }
6  topic: string
7  groupId?: string
8}): EventBus
  • emit() publishes JSON event payloads to Kafka.
  • subscribe() creates consumer flow and invokes handler per message.
  • Depends on runtime + events
  • Peer dependency: kafkajs@^2.0.0