Trait rdkafka::config::FromClientConfigAndContext

pub trait FromClientConfigAndContext<C: ClientContext>: Sized {
    fn from_config_and_context(_: &ClientConfig, _: C) -> KafkaResult<Self>;
}

Create a new client based on the provided configuration and context.

Required methods

fn from_config_and_context(_: &ClientConfig, _: C) -> KafkaResult<Self>

Creates a client from a client configuration and a client context.

Loading content...

Implementors

impl<C: ClientContext + 'static> FromClientConfigAndContext<C> for FutureProducer<C>

fn from_config_and_context(
    config: &ClientConfig,
    context: C
) -> KafkaResult<FutureProducer<C>>

impl<C: ClientContext> FromClientConfigAndContext<C> for AdminClient<C>

fn from_config_and_context(
    config: &ClientConfig,
    context: C
) -> KafkaResult<AdminClient<C>>

impl<C: ConsumerContext> FromClientConfigAndContext<C> for BaseConsumer<C>

Creates a new BaseConsumer starting from a ClientConfig.

fn from_config_and_context(
    config: &ClientConfig,
    context: C
) -> KafkaResult<BaseConsumer<C>>

impl<C: ConsumerContext> FromClientConfigAndContext<C> for StreamConsumer<C>

Creates a new StreamConsumer starting from a ClientConfig.

fn from_config_and_context(
    config: &ClientConfig,
    context: C
) -> KafkaResult<StreamConsumer<C>>

impl<C: ProducerContext + 'static> FromClientConfigAndContext<C> for ThreadedProducer<C>

fn from_config_and_context(
    config: &ClientConfig,
    context: C
) -> KafkaResult<ThreadedProducer<C>>

impl<C: ProducerContext> FromClientConfigAndContext<C> for BaseProducer<C>

fn from_config_and_context(
    config: &ClientConfig,
    context: C
) -> KafkaResult<BaseProducer<C>>

Creates a new BaseProducer starting from a configuration and a context.

Loading content...