Kafka bilan mikroxizmatlar o'rtasida asosiy o'zaro ta'sir qilish shablonlari qanday?

Kafka bilan mikroservislar bilan o'zaro ta'sir qilishning asosiy shablonlari:

1. Voqeaga asoslangan arxitektura (EDA) — mikroservislar Kafka ga voqealarni joylashtiradi, boshqa mikroservislar bu voqealarga obuna bo'ladi va ularga javob beradi. Bu asinxron xabar almashinuvi bo'lib, xizmatlar o'rtasidagi bog'liqlikni kamaytirishga imkon beradi.

2. Buyruq va so'rov mas'uliyatining ajralishi (CQRS) — buyruqlar va so'rovlar turli mikroservislar tomonidan ishlanadi, va Kafka holat o'zgarishi bo'yicha buyruqlar yoki voqealarni uzatish uchun ishlatiladi.

3. Voqea manbai (Event Sourcing) — mikroservisning barcha holat o'zgarishlari Kafka da voqealar ketma-ketligi sifatida saqlanadi, bu holatni tiklash yoki audit qilish imkonini beradi.

4. Loglarni yig'ish — Kafka mikroservislar loglari va metrikalarni yig'ish uchun ishlatiladi va keyinchalik tahlil qilish uchun.

Sodda Go ishlab chiqaruvchining misoli, sarama kutubxonasi yordamida:

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: "events",
        Value: sarama.StringEncoder("Hello Kafka"),
    }

    partition, offset, err := producer.SendMessage(msg)
    if err != nil {
        log.Fatal(err)
    }
    log.Printf("Xabar partiyaga %d, offset %d da saqlanadi\n", partition, offset)
}