Koju biblioteku ste koristili za interakciju sa Kafka?

Za interakciju sa Kafka na jeziku Go često se koristi biblioteka Shopify/sarama. To je popularan i dobro podržan Kafka klijent za Go, koji pruža kompletan skup funkcija za producente i konzumente.

Primer jednostavnog producenta koristeći sarama:

package main

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

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

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

    partition, offset, err := producer.SendMessage(msg)
    if err != nil {
        log.Fatal("Neuspešno slanje poruke", err)
    }

    log.Printf("Poruka poslata na partition %d na offset %d", partition, offset)
}

Pored sarama, postoje i druge biblioteke, poput segmentio/kafka-go, ali sarama je jedna od najraširenijih.