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

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

Required Methods§

source

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

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

Object Safety§

This trait is not object safe.

Implementors§

source§

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

source§

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

source§

impl<C, R> FromClientConfigAndContext<C> for StreamConsumer<C, R>
where C: ConsumerContext + 'static, R: AsyncRuntime,

Creates a new StreamConsumer starting from a ClientConfig.

source§

impl<C, R> FromClientConfigAndContext<C> for FutureProducer<C, R>
where C: ClientContext + 'static, R: AsyncRuntime,

source§

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

source§

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

Creates a new BaseConsumer starting from a ClientConfig.