Trait rdkafka::config::FromClientConfigAndContext
source · [−]pub trait FromClientConfigAndContext<C: ClientContext>: Sized {
fn from_config_and_context(_: &ClientConfig, _: C) -> KafkaResult<Self>;
}
Expand description
Create a new client based on the provided configuration and context.
Required methods
fn from_config_and_context(_: &ClientConfig, _: C) -> KafkaResult<Self>
fn from_config_and_context(_: &ClientConfig, _: C) -> KafkaResult<Self>
Creates a client from a client configuration and a client context.
Implementors
impl<C> FromClientConfigAndContext<C> for ThreadedProducer<C> where
C: ProducerContext + '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,
Creates a new BaseConsumer
starting from a ClientConfig
.