event-driven-architect

Event-Driven Architect

Workflow

1. Identifier les événements métier

Modéliser les faits immuables nommés au passé (verbe passé + sujet) :

OrderPlaced / PaymentProcessed / UserRegistered / ShipmentDispatched

Distinguer deux types :

• Domain event : interne à un bounded context (même déploiement possible).
• Integration event : traverse les frontières de service → passe obligatoirement par un broker.

Pratiquer l'Event Storming pour découvrir les événements avec les parties métier avant d'écrire la moindre ligne de code.

---

2. Choisir le broker

Critère	RabbitMQ	Kafka	Azure Service Bus	Redis Streams
Débit	Moyen (50 k msg/s)	Très élevé (M msg/s)	Moyen	Faible-moyen
Rétention	Non (ack = supprimé)	Oui (configurable)	14 jours max	Configurable
Ordering strict	Par queue	Par partition	Par session	Par stream
Rejeu	Non natif	Oui	Non natif	Oui
Complexité opé.	Faible	Élevée	Faible (SaaS)	Très faible

Règle de sélection :

• Audit trail / event sourcing / gros débit → Kafka
• Workflow, saga, routing complexe → RabbitMQ
• Équipe Azure sans infra dédiée → Azure Service Bus
• Cache + messaging léger → Redis Streams

---

3. Topologie topics / queues

RabbitMQ — exchange fanout + routing :

Exchange: order.events (type: topic)
  → order.placed        → queue: billing.order-placed
  → order.placed        → queue: inventory.order-placed
  → order.cancelled     → queue: billing.order-cancelled

Kafka — topics + partitions :

Topic: order-events          (partitions: 12, replication: 3)
Topic: payment-events        (partitions: 6,  replication: 3)
Consumer group: billing-svc  → offset par partition géré par Kafka

Règle : 1 consumer group = 1 responsabilité. Ne pas partager un group entre services différents.

---

4. Implémenter le pattern

Pub/Sub (découplage simple)

// Producteur (.NET + MassTransit + RabbitMQ)
await _publishEndpoint.Publish(new OrderPlaced
{
    OrderId   = order.Id,
    CustomerId = order.CustomerId,
    OccurredAt = DateTimeOffset.UtcNow
});

// Consommateur
public class OrderPlacedConsumer : IConsumer<OrderPlaced>
{
    public async Task Consume(ConsumeContext<OrderPlaced> context)
    {
        // logique idempotente ici
    }
}