Китобхонаеро, ки барои муошират бо Kafka истифода бурдед, кадом аст?

Барои муоширати бо Kafka дар забони Go, аксар вақт аз китобхонаи Shopify/sarama истифода мешавад. Ин як мизоҷи маъруфи Kafka барои Go аст, ки маҷмӯи пурраи функсияҳоро барои истеҳсолкунандагон ва истеъмолкунандагон пешниҳод мекунад.

Маслиҳати як истеҳсолкунандаи оддӣ бо истифода аз сарма:

package main

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

func main() {
    producer, err := sarama.NewSyncProducer([]string{"localhost:9092"}, nil)
    if err != nil {
        log.Fatal("Хатогӣ дар сохтани истеҳсолкунандаи", err)
    }
    defer producer.Close()

    msg := &sarama.ProducerMessage{
        Topic: "test_topic",
        Value: sarama.StringEncoder("Салом Kafka"),
    }

    partition, offset, err := producer.SendMessage(msg)
    if err != nil {
        log.Fatal("Намудани паём", err)
    }

    log.Printf("Паём ба partition %d дар offset %d фиристода шуд", partition, offset)
}

Илова бар сарма, китобхонаҳои дигар ҳам ҳастанд, масалан segmentio/kafka-go, аммо сарма яке аз маъмултаринҳост.