Trait rdkafka_wrap::config::FromClientConfigAndContext

pub trait FromClientConfigAndContext<C>: Sized
where
    C: ClientContext,
{
    // Required method
    fn from_config_and_context(
        _: &ClientConfig,
        _: C
    ) -> Result<Self, KafkaError>;
}

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

Required Methods

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

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

Object Safety

This trait is not object safe.

Implementors

impl<C> FromClientConfigAndContext<C> for AdminClient<C>

where C: ClientContext,

impl<C> FromClientConfigAndContext<C> for BaseConsumer<C>

where C: ConsumerContext,

Creates a new BaseConsumer starting from a ClientConfig.

impl<C, Part> FromClientConfigAndContext<C> for HpProducer<C, Part>

where Part: Partitioner + Send + Sync + 'static, C: ProducerContext<Part> + 'static,

impl<C, Part> FromClientConfigAndContext<C> for BaseProducer<C, Part>

where Part: Partitioner, C: ProducerContext<Part>,

impl<C, Part> FromClientConfigAndContext<C> for ThreadedProducer<C, Part>

where Part: Partitioner + Send + Sync + 'static, C: ProducerContext<Part> + 'static,

impl<C, R> FromClientConfigAndContext<C> for StreamConsumer<C, R>

where C: ConsumerContext + 'static, R: AsyncRuntime,

Creates a new StreamConsumer starting from a ClientConfig.

impl<C, R> FromClientConfigAndContext<C> for FutureProducer<C, R>

where C: ClientContext + 'static, R: AsyncRuntime,