Arquitectura Orientada a Eventos y Servicios con Apache Kafka

Imagina que tienes una tienda online. Un cliente hace un pedido. ¿Qué tiene que pasar después? Enviar email de confirmación, descontar del inventario, notificar al almacén, actualizar puntos de fidelidad, generar el cobro... Si todo eso tuviera que hacerse uno a uno, en secuencia, tu sistema sería una pesadilla.

Ese es exactamente el problema que resuelve la Arquitectura Orientada a Eventos. Y Apache Kafka es una de las herramientas más potentes para implementarla.

1. Tradicional vs Orientada a Eventos: ¿Cuál es la diferencia?

En una arquitectura tradicional (síncrona), los servicios se llaman directamente entre ellos. El Servicio A llama al Servicio B, espera respuesta, luego llama al C, espera, y así sucesivamente.

En una arquitectura orientada a eventos, los servicios no se llaman entre sí. En cambio, publican eventos a un canal central (como Kafka) y otros servicios escuchan esos eventos de forma independiente.

2. ¿Qué es Apache Kafka?

Kafka es una plataforma de mensajería distribuida. Imagínala como una oficina de correos superpotente, extremadamente rápida y confiable. Los servicios dejan mensajes ahí, y otros servicios los recogen cuando están listos.

3. Conceptos clave (en lenguaje sencillo)

4. Kafka en .NET — Productor

Instala el cliente oficial de Kafka para .NET:

dotnet add package Confluent.Kafka

Un Productor envía eventos a un topic de Kafka. En nuestro ejemplo, el servicio de pedidos publica un evento cada vez que se crea uno:

public class OrderProducer
{
    private readonly IProducer<string, string> _producer;

    public OrderProducer()
    {
        var config = new ProducerConfig
        {
            BootstrapServers = "localhost:9092" // dirección del servidor Kafka
        };
        _producer = new ProducerBuilder<string, string>(config).Build();
    }

    public async Task PublishOrderCreatedAsync(string orderId)
    {
        var message = new Message<string, string>
        {
            Key   = orderId,              // agrupa mensajes del mismo pedido
            Value = $"{{\"orderId\":\"{orderId}\",\"status\":\"created\"}}"
        };

        await _producer.ProduceAsync("pedido-creado", message);

        Console.WriteLine($"✅ Evento publicado: pedido {orderId}");
    }
}

5. Kafka en .NET — Consumidor

Un Consumidor escucha el topic y reacciona a cada evento. Aquí el servicio de email escucha y envía una confirmación:

public class EmailConsumer : BackgroundService
{
    protected override async Task ExecuteAsync(CancellationToken ct)
    {
        var config = new ConsumerConfig
        {
            BootstrapServers = "localhost:9092",
            GroupId          = "email-service-group", // ID del grupo
            AutoOffsetReset  = AutoOffsetReset.Earliest
        };

        using var consumer = new ConsumerBuilder<string, string>(config).Build();
        consumer.Subscribe("pedido-creado"); // suscribirse al topic

        while (!ct.IsCancellationRequested)
        {
            var result = consumer.Consume(ct); // espera el siguiente mensaje

            Console.WriteLine($"📧 Enviando email para pedido: {result.Message.Key}");

            await SendConfirmationEmailAsync(result.Message.Value);
        }
    }
}

6. ¿Cuándo usar Kafka?

7. Ejemplo real: Flujo de pedido en e-commerce

8. Kafka vs otras colas

Resumen

¿Preguntas o quieres que profundice — Kafka Streams, KSQL o event sourcing con .NET? Escríbeme a felipe@faraujop.com o por WhatsApp.

Felipe Araujo Pacheco

Tech Lead & Engineering Manager con 15+ años en .NET, cloud y arquitectura de microservicios. Actualmente en Eni Plenitude Iberia, Santander.

Ver portfolio →