Apache Kafka مدیریت‌شده برای استریم رویداد

رویدادها، ماندگار و قابل بازخوانی

Kafka برای جریان پیوسته‌ی رویداد ساخته شده است: لاگ تغییرات، کلیک‌استریم، داده‌ی سنسور و ارتباط سرویس‌ها در معماری رویدادمحور. پیام‌ها پس از مصرف حذف نمی‌شوند و هر consumer group از جای خودش می‌خواند.

اتصال با SASL/PLAIN احراز هویت می‌شود. میزبان، نام کاربری و رمز را از sakoocloud db credentials بردارید و به اپ بدهید؛ کلاینت‌هایی مثل kafkajs، confluent-kafka و franz-go با همین سه مقدار وصل می‌شوند.

از ساخت تا اتصال

1. ساخت

   نسخه را انتخاب کنید.

   --type kafka --version 4.3.0

2. اطلاعات اتصال

   میزبان، نام کاربری و رمز SASL را بگیرید.

   db credentials

3. تعریف متغیرها

   مقدارها را به‌صورت متغیر محیطی به اپ بدهید.

   env set KAFKA_HOST=…

خروجی ساخت سرویس

$ sakoocloud db create --name events --type kafka --version 4.3.0
✔ Provisioning events · db_4n8x2p
$ sakoocloud db credentials db_4n8x2p
$ sakoocloud env set KAFKA_HOST=… KAFKA_USER=… KAFKA_PASSWORD=•••• --app my-api

ساخت کلاستر

با CLI یا از کنسول.

sakoocloud db create --name events --type kafka --version 4.3.0

تنظیمات

اتصال از اپ

میزبان و اطلاعات SASL را از متغیرها بخوانید.

import { Kafka } from "kafkajs";

const kafka = new Kafka({
  brokers: [`${process.env.KAFKA_HOST}:9092`],
  sasl: {
    mechanism: "plain",
    username: process.env.KAFKA_USER,
    password: process.env.KAFKA_PASSWORD,
  },
});

import os
from confluent_kafka import Producer

p = Producer({
    "bootstrap.servers": os.environ["KAFKA_HOST"] + ":9092",
    "security.protocol": "SASL_PLAINTEXT",
    "sasl.mechanism": "PLAIN",
    "sasl.username": os.environ["KAFKA_USER"],
    "sasl.password": os.environ["KAFKA_PASSWORD"],
})

خطاهای رایج

پرسش‌های متداول

جزئیات بیشتر در راهنمای Kafka در مستندات و مرجع CLI.