Kuru bibliotēku jūs izmantojāt, lai sadarboties ar Kafka?

Lai sadarboties ar Kafka Go valodā, bieži tiek izmantota bibliotēka Shopify/sarama. Tā ir populāra un labi atbalstīta Kafka klienta bibliotēka Go valodai, kas nodrošina pilnu funkcionalitātes komplektu producēšanai un patērēšanai.

Vienkārša producētāja piemērs, izmantojot sarama:

package main

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

func main() {
    producer, err := sarama.NewSyncProducer([]string{"localhost:9092"}, nil)
    if err != nil {
        log.Fatal("Kļūda, veidojot producētāju", err)
    }
    defer producer.Close()

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

    partition, offset, err := producer.SendMessage(msg)
    if err != nil {
        log.Fatal("Kļūda, sūtot ziņu", err)
    }

    log.Printf("Ziņa nosūtīta uz daļu %d, offsetu %d", partition, offset)
}

Papildus sarama, ir arī citas bibliotēkas, piemēram, segmentio/kafka-go, bet sarama ir viena no visplašāk izmantotajām.