consumer

Function consumer 

Source
pub fn consumer(
    servers: impl IntoIterator<Item = impl ToString>,
    topic: &str,
    config: KafkaConsumerConfig,
) -> Result<KafkaConsumer, SdkError>
Expand description

Connects to Kafka servers and creates a new Kafka consumer.