Struct KafkaAdmin 

pub struct KafkaAdmin { /* private fields */ }

Client for Kafka admin operations.

Implementations

impl KafkaAdmin

pub async fn connect(config: AdminConfig) -> Result<Self>

Connects to Kafka and returns the client.

pub async fn create_topics<I>(&self, topics: I) -> Result<()>

where I: IntoIterator<Item = NewTopic>,

Create Topics.

pub async fn delete_topics<I, S>(&self, topics: I) -> Result<()>

where I: IntoIterator<Item = S>, S: Into<String>,

Delete Topics.

pub async fn create_partitions<I, S>(&self, partitions: I) -> Result<()>

where I: IntoIterator<Item = (S, NewPartitions)>, S: Into<String>,

Create Partitions.

pub async fn list_topics(&self) -> Result<Vec<TopicListing>>

List Topics.

pub async fn describe_topics<I, S>( &self, topics: I, ) -> Result<Vec<TopicDescription>>

where I: IntoIterator<Item = S>, S: Into<String>,

Describe Topics.

pub async fn describe_cluster(&self) -> Result<ClusterDescription>

Describe Cluster.

pub async fn list_consumer_groups(&self) -> Result<Vec<ConsumerGroupListing>>

List Consumer Groups.

pub async fn describe_consumer_groups<I, S>( &self, groups: I, ) -> Result<Vec<ConsumerGroupDescription>>

where I: IntoIterator<Item = S>, S: Into<String>,

Describe Consumer Groups.

pub async fn delete_consumer_groups<I, S>(&self, groups: I) -> Result<()>

where I: IntoIterator<Item = S>, S: Into<String>,

Delete Consumer Groups.

pub async fn describe_configs<I>( &self, resources: I, ) -> Result<Vec<ConfigResourceConfig>>

where I: IntoIterator<Item = ConfigResource>,

Describe Configs.

pub async fn incremental_alter_configs<I>(&self, resources: I) -> Result<()>

where I: IntoIterator<Item = (ConfigResource, Vec<AlterConfigOp>)>,

Incremental Alter Configs.

pub async fn upsert_scram_credential( &self, user: impl Into<String>, mechanism: SaslMechanism, password: impl AsRef<[u8]>, ) -> Result<()>

Upsert Scram Credential.

pub async fn upsert_scram_credential_with_iterations( &self, user: impl Into<String>, mechanism: SaslMechanism, password: impl AsRef<[u8]>, iterations: i32, ) -> Result<()>

Upsert Scram Credential With Iterations.

pub fn config(&self) -> &AdminConfig

Config.

pub async fn finalized_feature_levels(&self) -> Result<Vec<BrokerFeatureLevel>>

Finalized Feature Levels.

Trait Implementations

impl Clone for KafkaAdmin

fn clone(&self) -> KafkaAdmin

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for KafkaAdmin

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.