Function mz_sql::kafka_util::create_consumer

pub async fn create_consumer(
    connection_context: &ConnectionContext,
    kafka_connection: &KafkaConnection,
    topic: &str
) -> Result<Arc<BaseConsumer<BrokerRewritingClientContext<MzClientContext>>>, PlanError>

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.

Panics

• options does not contain bootstrap.servers as a key

Errors

• librdkafka cannot create a BaseConsumer using the provided options.