Kuru ziņojumu starpnieku jūs vēlētos izmantot — Kafka vai RabbitMQ?

Izvēle starp Kafka un RabbitMQ ir atkarīga no projekta konkrētajām prasībām.

Kafka ir piemērotāks lielu datu plūsmu apstrādei ar augstu caurlaidspēju un ziņojumu glabāšanu (notikumu žurnāls). Tas ir orientēts uz mērogojamību un izturību, un tas ir ideāli piemērots analītikas sistēmām, straumes apstrādei un notikumu sistēmām.

RabbitMQ ir klasiskā ziņojumu starpnieks, kas atbalsta dažādus apmaiņas modeļus (rindas, tēmas), un ir ērts uzdevumiem ar garantētu piegādi, sarežģītu maršrutēšanu un starp pakalpojumu integrāciju.

Ja nepieciešams augsts veiktspējas līmenis un lielu datu apstrāde — izmantojiet Kafka. Ja svarīga ir elastīga maršrutēšana un uzticama piegāde — izmantojiet RabbitMQ.

Piemērs Kafka izmantošanai Go valodā (ar sarama bibliotēku):

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

    partition, offset, err := producer.SendMessage(msg)
    if err != nil {
        log.Fatal(err)
    }
    log.Printf("Ziņa ir saglabāta partitijā %d, ofsetā %d\n", partition, offset)
}