Quels sont les principaux modèles d'interaction de Kafka avec les microservices que vous connaissez?

Les principaux modèles d'interaction de Kafka avec les microservices:

1. Architecture orientée événements (EDA) — les microservices publient des événements dans Kafka, d'autres microservices s'abonnent à ces événements et y réagissent. C'est un échange de messages asynchrone qui permet de réduire le couplage entre les services.

2. Segregation des responsabilités Commande-Requête (CQRS) — les commandes et requêtes sont traitées par différents microservices, et Kafka est utilisé pour transmettre des commandes ou des événements de changement d'état.

3. Event Sourcing — toutes les modifications d'état du microservice sont stockées comme une séquence d'événements dans Kafka, ce qui permet de restaurer l'état ou de faire des audits.

4. Agrégation de logs — Kafka est utilisé pour collecter les logs et métriques des microservices pour une analyse ultérieure.

Exemple d'un producteur simple en Go utilisant la bibliothèque sarama:

package main

import (
    "github.com/Shopify/sarama"
    "log"
)

func main() {
    producer, err := sarama.NewSyncProducer([]string{"localhost:9092"}, nil)
    if err != nil {
        log.Fatal(err)
    }
    defer producer.Close()

    msg := &sarama.ProducerMessage{
        Topic: "events",
        Value: sarama.StringEncoder("Hello Kafka"),
    }

    partition, offset, err := producer.SendMessage(msg)
    if err != nil {
        log.Fatal(err)
    }
    log.Printf("Le message est stocké dans la partition %d, offset %d\n", partition, offset)
}