Function mz_storage::source::kafka::create_kafka_config

async fn create_kafka_config(
    connection_id: GlobalId,
    source_id: GlobalId,
    group_id_prefix: Option<String>,
    environment_id: String,
    kafka_connection: &KafkaConnection,
    options: &BTreeMap<String, StringOrSecret>,
    connection_context: &ConnectionContext
) -> ClientConfig

Creates a Kafka config.

options set additional configuration operations from the user. While these look arbitrary, other layers of the system tightly control which configuration options are allowable.