Module utils 

Utils module.

Overview

This module contains utility functions for the DS Event Stream.

Features

• Get the topics for the DS Event Stream.

Example

use ds_event_stream_rs_sdk::utils::{list_topics, get_topic, get_bootstrap_servers, Environment, ClientCredentials};

let bootstrap_servers = get_bootstrap_servers(Environment::Development, false);
let credentials = ClientCredentials { username: "username".to_string(), password: "password".to_string() };

let topic = get_topic(&bootstrap_servers, &credentials, "topic_name");
let topics = list_topics(&bootstrap_servers, &credentials);

Modules

error

Utils error module.

Structs

ClientCredentials

Client credentials for Kafka authentication.

Enums

Environment

The environment of the DS Event Stream.

Functions

get_bootstrap_servers

Get the bootstrap servers for the DS Event Stream.

get_topic

Get the name of a specific topic.

list_topics

List the topics for the DS Event Stream.