Kurį pranešimų tarpininką norėtumėte naudoti — Kafka ar RabbitMQ?

Pasirinkimas tarp Kafka ir RabbitMQ priklauso nuo projekto konkrečių reikalavimų.

Kafka yra tinkamesnis dideliems duomenų srautams apdoroti su aukštu pralaidumu ir žinučių saugojimu (įvykių žurnalas). Jis orientuotas į mastelį ir atsparumą, ir puikiai tinka analitikos sistemoms, srautiniam apdorojimui ir įvykių sistemoms.

RabbitMQ yra klasikinis žinučių tarpininkas, palaikantis įvairius mainų modelius (eilės, temos), ir yra patogus užduotims su garantuotu pristatymu, sudėtingu maršrutizavimu ir tarp paslaugų integracija.

Jei reikia aukšto našumo ir didelių duomenų apdorojimo — naudokite Kafka. Jei svarbi lanksti maršrutizacija ir patikimas pristatymas — naudokite RabbitMQ.

Pavyzdys Kafka naudojimo Go kalba (su sarama biblioteka):

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

    partition, offset, err := producer.SendMessage(msg)
    if err != nil {
        log.Fatal(err)
    }
    log.Printf("Žinutė išsaugota partition %d, offset %d\n", partition, offset)
}