Ce bibliotecă ai folosit pentru a interacționa cu Kafka?

Pentru a interacționa cu Kafka în limbajul Go, se folosește adesea biblioteca Shopify/sarama. Este un client Kafka popular și bine suportat pentru Go, care oferă un set complet de funcții pentru producători și consumatori.

Exemplu de un producător simplu folosind sarama:

package main

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

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

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

    partition, offset, err := producer.SendMessage(msg)
    if err != nil {
        log.Fatal("Eroare la trimiterea mesajului", err)
    }

    log.Printf("Mesaj trimis către partiția %d la offset-ul %d", partition, offset)
}

Pe lângă sarama, există și alte biblioteci, precum segmentio/kafka-go, dar sarama este una dintre cele mai răspândite.