Event-Driven Architecture for E-Commerce: Kafka & Webhooks

Kafka Producer Node.js Code

// Node.js Kafka Producer for E-Commerce Order Placed Event
const { Kafka } = require('kafkajs');

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

async function publishOrderPlaced(order) {
  await producer.connect();
  await producer.send({
    topic: 'order-events',
    messages: [
      { key: order.id, value: JSON.stringify({ event: 'ORDER_PLACED', order }) }
    ],
  });
}