Kokią biblioteką naudojote sąveikai su Kafka?

Norint sąveikauti su Kafka naudojant Go kalbą, dažnai naudojama biblioteka Shopify/sarama. Tai populiarus ir gerai palaikomas Kafka klientas Go kalbai, kuris suteikia pilną funkcijų rinkinį gamintojams ir vartotojams.

Paprasto gamintojo pavyzdys naudojant sarama:

package main

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

func main() {
    producer, err := sarama.NewSyncProducer([]string{"localhost:9092"}, nil)
    if err != nil {
        log.Fatal("Klaida kuriant gamintoją", err)
    }
    defer producer.Close()

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

    partition, offset, err := producer.SendMessage(msg)
    if err != nil {
        log.Fatal("Klaida siunčiant žinutę", err)
    }

    log.Printf("Žinutė išsiųsta į dalį %d, offsetą %d", partition, offset)
}

Be sarama, yra ir kitų bibliotekų, pavyzdžiui, segmentio/kafka-go, tačiau sarama yra viena iš labiausiai paplitusių.