Function sql::kafka_util::create_consumer [−][src]
pub async fn create_consumer(
broker: &str,
topic: &str,
options: &BTreeMap<String, String>
) -> Result<Arc<BaseConsumer<KafkaErrCheckContext>>, Error>
Expand description
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 providedoptions
. For example, when using Kerberos auth, and the named principal does not exist.