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.
pub fn consumer(
servers: impl IntoIterator<Item = impl ToString>,
topic: &str,
config: KafkaConsumerConfig,
) -> Result<KafkaConsumer, SdkError>
Connects to Kafka servers and creates a new Kafka consumer.