Koji broker poruka biste radije koristili — Kafka ili RabbitMQ?

Izbor između Kafka i RabbitMQ zavisi od specifičnih zahteva projekta.

Kafka je pogodniji za obradu velikih tokova podataka sa visokim kapacitetom prenosa i skladištenjem poruka (zapis događaja). Usmeren je na skalabilnost i otpornost, i pogodan je za analitičke sisteme, obradu u toku i događajne sisteme.

RabbitMQ je klasični posrednik poruka koji podržava različite modele razmene (redove, teme), i pogodan je za zadatke sa garantovanim dostavom, složenim rutiranjem i integracijom između servisa.

Ako vam je potrebna visoka performansa i obrada velikih količina podataka — koristite Kafka. Ako je važna fleksibilna rutiranje i pouzdana dostava — koristite RabbitMQ.

Primer korišćenja Kafka u Go (sa bibliotekom sarama):

package main

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

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("Zdravo Kafka"),
    }

    partition, offset, err := producer.SendMessage(msg)
    if err != nil {
        log.Fatal(err)
    }
    log.Printf("Poruka je sačuvana u particiji %d, ofsetu %d\n", partition, offset)
}