Ktorého broker na správu správ by ste radšej používali — Kafka alebo RabbitMQ?

Voľba medzi Kafka a RabbitMQ závisí od špecifických požiadaviek projektu.

Kafka je vhodnejší na spracovanie veľkých tokov dát s vysokou priepustnosťou a ukladaním správ (záznam udalostí). Je zameraný na škálovateľnosť a odolnosť a je vhodný pre analytické systémy, streamové spracovanie a systémové udalosti.

RabbitMQ je klasický broker správ, ktorý podporuje rôzne modely výmeny (fronty, témy), a je vhodný pre úlohy s garantovaným doručením, zložitým smerovaním a integráciou medzi službami.

Ak potrebujete vysoký výkon a spracovanie veľkých objemov dát — použite Kafka. Ak je dôležitá flexibilná smerovanie a spoľahlivé doručenie — použite RabbitMQ.

Príklad použitia Kafka v Go (s knižnicou 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("Ahoj Kafka"),
    }

    partition, offset, err := producer.SendMessage(msg)
    if err != nil {
        log.Fatal(err)
    }
    log.Printf("Správa je uložená v partition %d, offset %d\n", partition, offset)
}