Skip to main content

create_consumer

kafka_common::client

Function create_consumer 

Source 
pub fn create_consumer(config: &KafkaConsumerConfig) -> Result<StreamConsumer>
Expand description

Creates a StreamConsumer based on the given configuration.