Quelle bibliothèque avez-vous utilisée pour interagir avec Kafka?

Pour interagir avec Kafka en langage Go, la bibliothèque Shopify/sarama est souvent utilisée. C'est un client Kafka populaire et bien supporté pour Go, qui offre un ensemble complet de fonctionnalités pour les producteurs et les consommateurs.

Exemple d'un producteur simple utilisant sarama :

package main

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

func main() {
    producer, err := sarama.NewSyncProducer([]string{"localhost:9092"}, nil)
    if err != nil {
        log.Fatal("Erreur lors de la création du producteur", err)
    }
    defer producer.Close()

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

    partition, offset, err := producer.SendMessage(msg)
    if err != nil {
        log.Fatal("Échec de l'envoi du message", err)
    }

    log.Printf("Message envoyé à la partition %d à l'offset %d", partition, offset)
}

En plus de sarama, il existe d'autres bibliothèques, comme segmentio/kafka-go, mais sarama est l'une des plus répandues.