Millist sõnumi vahendajat eelistaksite kasutada — Kafka või RabbitMQ?

Projektide konkreetsete nõuete põhjal tehakse valik Kafka ja RabbitMQ vahel.

Kafka sobib paremini suurte andmevoogude töötlemiseks kõrge läbilaskevõime ja sõnumite salvestamisega (sündmuste log). See on suunatud skaleeritavusele ja vastupidavusele ning sobib analüütika, voogude töötlemise ja sündmussüsteemide jaoks.

RabbitMQ on klassikaline sõnumivahetaja, mis toetab erinevaid vahetusmudeleid (järjekorrad, teemad) ning on mugav ülesannete jaoks, mis nõuavad garanteeritud kohaletoimetamist, keerukat marsruutimist ja teenuste vahelise integratsiooni.

Kui on vaja kõrget jõudlust ja suurte andmemahtude töötlemist — kasutage Kafka-d. Kui oluline on paindlik marsruutimine ja usaldusväärne kohaletoimetamine — kasutage RabbitMQ-d.

Näide Kafka kasutamisest Go keeles (sarama teegiga):

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

    partition, offset, err := producer.SendMessage(msg)
    if err != nil {
        log.Fatal(err)
    }
    log.Printf("Sõnum salvestati partition %d, offset %d\n", partition, offset)
}