@loop-engine/adapter-kafka

Kafka event adapter for Loop Engine - publish loop events to Kafka topics for streaming and analytics.

Install

npm install @loop-engine/adapter-kafka kafkajs

Quick Start

import { Kafka } from "kafkajs";
import { kafkaEventBus } from "@loop-engine/adapter-kafka";

const kafka = new Kafka({ clientId: "loop-engine", brokers: ["localhost:9092"] });
const eventBus = kafkaEventBus({
  kafka: { producer: () => kafka.producer(), consumer: () => kafka.consumer({ groupId: "loop-engine" }) } as never,
  topic: "loop-events"
});

Documentation link

https://loopengine.io/docs/integrations/kafka

License

Apache-2.0 © Better Data, Inc.