Kafka ile etkileşim kurmak için hangi kütüphaneyi kullandınız?

Go dilinde Kafka ile etkileşim kurmak için sıklıkla Shopify/sarama kütüphanesi kullanılır. Bu, Go için popüler ve iyi desteklenen bir Kafka istemcisidir ve üreticiler ve tüketiciler için tam bir özellik seti sağlar.

Sarama kullanarak basit bir üretici örneği:

package main

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

func main() {
    producer, err := sarama.NewSyncProducer([]string{"localhost:9092"}, nil)
    if err != nil {
        log.Fatal("Üretici oluşturulurken hata", err)
    }
    defer producer.Close()

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

    partition, offset, err := producer.SendMessage(msg)
    if err != nil {
        log.Fatal("Mesaj gönderilemedi", err)
    }

    log.Printf("Mesaj, %d partitionına, %d offsetine gönderildi", partition, offset)
}

Sarama dışında segmentio/kafka-go gibi diğer kütüphaneler de mevcuttur, ancak sarama en yaygın olanlardan biridir.