Welche Bibliothek haben Sie für die Interaktion mit Kafka verwendet?

Um mit Kafka in der Programmiersprache Go zu interagieren, wird häufig die Bibliothek Shopify/sarama verwendet. Es ist ein beliebter und gut unterstützter Kafka-Client für Go, der eine vollständige Funktionalität für Producer und Consumer bietet.

Beispiel für einen einfachen Producer mit sarama:

package main

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

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

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

    partition, offset, err := producer.SendMessage(msg)
    if err != nil {
        log.Fatal("Fehler beim Senden der Nachricht", err)
    }

    log.Printf("Nachricht an Partition %d bei Offset %d gesendet", partition, offset)
}

Neben sarama gibt es auch andere Bibliotheken, z.B. segmentio/kafka-go, aber sarama ist eine der am weitesten verbreiteten.