Function create_kafka_log_store 

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

Create a KafkaLogStore.