Na čo sa používal Kafka?

Apache Kafka je distribuovaná platforma pre streamovanie dát, ktorá sa používa na budovanie systémov výmeny správ s vysokou priepustnosťou a nízkou latenciou.

Hlavné použitia Kafka:

• Prenos a spracovanie veľkých tokov dát v reálnom čase.
• Organizácia frontov správ medzi mikroservismi.
• Zber a agregácia logov a metrík.
• Budovanie systémov založených na udalostiach (event-driven architecture).

Kafka zabezpečuje spoľahlivé ukladanie správ, škálovateľnosť a možnosť spracovania dát pomocou konzumentov.

Príklad použitia v Go s knižnicou sarama:

package main

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

func main() {
    producent, err := sarama.NewSyncProducer([]string{"localhost:9092"}, nil)
    if err != nil {
        log.Fatal(err)
    }
    defer producent.Close()

    správa := &sarama.ProducerMessage{
        Topic: "test_topic",
        Value: sarama.StringEncoder("Hello Kafka"),
    }

    časť, offset, err := producent.SendMessage(správa)
    if err != nil {
        log.Fatal(err)
    }
    log.Printf("Správa odoslaná do časti %d na offset %d", časť, offset)
}