Trait rdkafka::config::FromClientConfigAndContext [−][src]
Create a new client based on the provided configuration and context.
Required methods
fn from_config_and_context(_: &ClientConfig, _: C) -> KafkaResult<Self>
[src]
Creates a client from a client configuration and a client context.
Implementors
impl<C> FromClientConfigAndContext<C> for BaseProducer<C> where
C: ProducerContext,
[src]
C: ProducerContext,
fn from_config_and_context(
config: &ClientConfig,
context: C
) -> KafkaResult<BaseProducer<C>>
[src]
config: &ClientConfig,
context: C
) -> KafkaResult<BaseProducer<C>>
Creates a new BaseProducer
starting from a configuration and a
context.
impl<C> FromClientConfigAndContext<C> for ThreadedProducer<C> where
C: ProducerContext + 'static,
[src]
C: ProducerContext + 'static,
fn from_config_and_context(
config: &ClientConfig,
context: C
) -> KafkaResult<ThreadedProducer<C>>
[src]
config: &ClientConfig,
context: C
) -> KafkaResult<ThreadedProducer<C>>
impl<C, R> FromClientConfigAndContext<C> for StreamConsumer<C, R> where
C: ConsumerContext + 'static,
R: AsyncRuntime,
[src]
C: ConsumerContext + 'static,
R: AsyncRuntime,
Creates a new StreamConsumer
starting from a ClientConfig
.
fn from_config_and_context(
config: &ClientConfig,
context: C
) -> KafkaResult<Self>
[src]
config: &ClientConfig,
context: C
) -> KafkaResult<Self>
impl<C, R> FromClientConfigAndContext<C> for FutureProducer<C, R> where
C: ClientContext + 'static,
R: AsyncRuntime,
[src]
C: ClientContext + 'static,
R: AsyncRuntime,
fn from_config_and_context(
config: &ClientConfig,
context: C
) -> KafkaResult<FutureProducer<C, R>>
[src]
config: &ClientConfig,
context: C
) -> KafkaResult<FutureProducer<C, R>>
impl<C: ClientContext> FromClientConfigAndContext<C> for AdminClient<C>
[src]
fn from_config_and_context(
config: &ClientConfig,
context: C
) -> KafkaResult<AdminClient<C>>
[src]
config: &ClientConfig,
context: C
) -> KafkaResult<AdminClient<C>>
impl<C: ConsumerContext> FromClientConfigAndContext<C> for BaseConsumer<C>
[src]
Creates a new BaseConsumer
starting from a ClientConfig
.
fn from_config_and_context(
config: &ClientConfig,
context: C
) -> KafkaResult<BaseConsumer<C>>
[src]
config: &ClientConfig,
context: C
) -> KafkaResult<BaseConsumer<C>>