Kafka Streaming

from confluent_kafka import Consumer

CONFIG = {
    "bootstrap.servers": KAFKA_BROKERS,
    "auto.offset.reset": "latest",
    "security.protocol": "SASL_SSL",
    "sasl.mechanisms": "SCRAM-SHA-512",
    "sasl.username": KAFKA_USERNAME,
    "sasl.password": KAFKA_PASSWORD,
}

import { Kafka } from "kafkajs";

export const kafka = new Kafka({
  brokers: KAFKA_BROKERS.split(","),
  ssl: true,
  sasl: {
    mechanism: "scram-sha-512",
    username: KAFKA_USERNAME,
    password: KAFKA_PASSWORD,
  },
});

use rdkafka::config::ClientConfig;
use rdkafka::consumer::StreamConsumer;

let consumer: StreamConsumer = ClientConfig::new()
    .set("bootstrap.servers", &kafka_brokers)
    .set("auto.offset.reset", "latest")
    .set("security.protocol", "SASL_SSL")
    .set("sasl.mechanism", "SCRAM-SHA-512")
    .set("sasl.username", &kafka_username)
    .set("sasl.password", &kafka_password)
    .create()?;