Function create_kafka_log_store

pub async fn create_kafka_log_store(
    broker_endpoints: Vec<String>,
) -> KafkaLogStore

Create a KafkaLogStore.