Junior — Middle

Kafka менен өз ара аракеттенүү үчүн кайсы китепкананы колдондуңуз?

sobes.tech AI

AIден жооп

Go тилинде Kafka менен өз ара аракеттенүү үчүн көбүнчө Shopify/sarama китепканасы колдонулат. Бул Go үчүн популярдуу жана жакшы колдоо көрсөтүлгөн Kafka кардар, ал өнүмчүлөр жана керектөөчүлөр үчүн толук функциялар топтомун камсыздайт.

Жөнөкөй өнүмчүнүн мисалы sarama колдонуу менен:

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("Мессеж бөлүмгө %d, оффсетке %d жөнөтүлдү", partition, offset)
}

Saramaдан башка да башка китепканалар бар, мисалы segmentio/kafka-go, бирок sarama эң кеңири тараган.

Мурунку Кийинки