Welke hoofdpatronen van interactie tussen Kafka en microservices ken je?

De belangrijkste interactiepatronen van Kafka met microservices:

1. Event-Driven Architectuur (EDA) — microservices publiceren gebeurtenissen in Kafka, andere microservices abonneren zich op deze gebeurtenissen en reageren erop. Dit is een asynchrone berichtuitwisseling die de koppeling tussen services vermindert.

2. Command Query Responsibility Segregation (CQRS) — commando's en query's worden door verschillende microservices verwerkt, en Kafka wordt gebruikt om commando's of gebeurtenissen van statuswijzigingen over te brengen.

3. Event Sourcing — alle statuswijzigingen van de microservice worden opgeslagen als een reeks gebeurtenissen in Kafka, waardoor het mogelijk is om de status te herstellen of audits uit te voeren.

4. Logaggregatie — Kafka wordt gebruikt om logs en metrics van microservices te verzamelen voor latere analyse.

Voorbeeld van een eenvoudige producer in Go met behulp van de sarama-bibliotheek:

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("Bericht opgeslagen in partitie %d, offset %d\n", partition, offset)
}