Integrations

Kafka

What it does

Publishes Loop Engine events (LoopTransitionedEvent, LoopStartedEvent, LoopCompletedEvent, LearningSignalEmittedEvent) to Kafka topics. Use this for audit pipelines, analytics, and cross-system event triggers.

Quick setup

1. Install

   ⧉

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

2. Create adapter

   ⧉

   1import { KafkaAdapter } from "@loop-engine/adapter-kafka";
   2 
   3const kafka = new KafkaAdapter({
   4  brokers: ["kafka-1:9092", "kafka-2:9092"],
   5  topicPrefix: "loop-engine",
   6  clientId: "procurement-service"
   7});

3. Wire event emission

   ⧉

   1const loopSystem = await createLoopSystem({
   2  loops: [procurementLoop],
   3  eventSinks: [kafka]
   4});

Configuration reference

| Option | Type | Default | Description | |---|---|---|---| | brokers | string[] | required | Kafka broker list | | topicPrefix | string | loop-engine | Prefix for emitted event topics | | clientId | string | loop-engine | Kafka client ID | | ssl | boolean | false | Enable TLS | | sasl | object | — | SASL credentials and mechanism |

Troubleshooting

• Connection timeout — Check broker addresses and network policy/firewall.
• Authentication error — Validate sasl mechanism/user/secret.
• Topic missing — Enable topic auto-create or pre-create topics manually.

Related

• Event Streaming example
• Events package
• Postgres integration