Function sql::kafka_util::create_consumer

pub async fn create_consumer(
    broker: &str, 
    topic: &str, 
    options: &BTreeMap<String, String>
) -> Result<Arc<BaseConsumer<KafkaErrCheckContext>>, Error>

Create a new rdkafka::ClientConfig with the provided options, and test its ability to create an rdkafka::consumer::BaseConsumer.

Expected to test the output of extract_security_config.

Errors

• librdkafka cannot create a BaseConsumer using the provided options. For example, when using Kerberos auth, and the named principal does not exist.