import { Kafka } from "kafkajs";

const kafka = new Kafka({ clientId: "orders-service", brokers: ["kafka:9092"] });
const producer = kafka.producer();

async function publishOrderCreated(order: Order): Promise<void> {
  await producer.send({
    topic: "order-events",
    messages: [{
      key: order.id,
      value: JSON.stringify({
        type: "ORDER_CREATED",
        version: "1.0",
        timestamp: new Date().toISOString(),
        payload: { orderId: order.id, userId: order.userId, items: order.items, total: order.total },
      }),
    }],
  });
}

const consumer = kafka.consumer({ groupId: "notifications-service" });
await consumer.subscribe({ topic: "order-events", fromBeginning: false });

await consumer.run({
  eachMessage: async ({ message }) => {
    const event = JSON.parse(message.value!.toString());
    if (event.type === "ORDER_CREATED") {
      await notificationService.sendConfirmation(event.payload);
    }
  },
});

Event-Driven Architecture — ארכיטקטורה מונחית אירועים

Event-Driven Architecture — ארכיטקטורה מונחית אירועים

Event-Driven Architecture — ארכיטקטורה מונחית אירועים