Trait rdkafka::config::FromClientConfig

pub trait FromClientConfig: Sized {
    fn from_config(_: &ClientConfig) -> KafkaResult<Self>;
}

Create a new client based on the provided configuration.

Required methods

fn from_config(_: &ClientConfig) -> KafkaResult<Self>

Creates a client from a client configuration. The default client context will be used.

Loading content...

Implementors

impl FromClientConfig for AdminClient<DefaultClientContext>

fn from_config(
    config: &ClientConfig
) -> KafkaResult<AdminClient<DefaultClientContext>>

impl FromClientConfig for BaseConsumer

fn from_config(config: &ClientConfig) -> KafkaResult<BaseConsumer>

impl FromClientConfig for BaseProducer<DefaultProducerContext>

fn from_config(
    config: &ClientConfig
) -> KafkaResult<BaseProducer<DefaultProducerContext>>

Creates a new BaseProducer starting from a configuration.

impl FromClientConfig for FutureProducer

fn from_config(config: &ClientConfig) -> KafkaResult<FutureProducer>

impl FromClientConfig for ThreadedProducer<DefaultProducerContext>

fn from_config(
    config: &ClientConfig
) -> KafkaResult<ThreadedProducer<DefaultProducerContext>>

impl<R> FromClientConfig for StreamConsumer<DefaultConsumerContext, R> where
    R: AsyncRuntime, 

fn from_config(config: &ClientConfig) -> KafkaResult<Self>

Loading content...