Kafka ilə əlaqə qurmaq üçün hansı kitabxanadan istifadə etdiniz?

Go dilində Kafka ilə qarşılıqlı əlaqə qurmaq üçün tez-tez Shopify/sarama kitabxanası istifadə olunur. Bu, Go üçün məşhur və yaxşı dəstəklənən Kafka müştərisidir və istehsalçılar və istehlakçılar üçün tam funksiyalar dəstini təmin edir.

Sarama istifadə edərək sadə bir istehsalçı nümunəsi:

package main

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

func main() {
    producer, err := sarama.NewSyncProducer([]string{"localhost:9092"}, nil)
    if err != nil {
        log.Fatal("İstehsalçı yaradılarkən xəta", err)
    }
    defer producer.Close()

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

    partition, offset, err := producer.SendMessage(msg)
    if err != nil {
        log.Fatal("Mesaj göndərilməsində xəta", err)
    }

    log.Printf("Mesaj %d partiyasına, %d offsetə göndərildi", partition, offset)
}

Sarama-dan başqa, segmentio/kafka-go kimi digər kitabxanalar da mövcuddur, lakin sarama ən çox yayılmışlardan biridir.