Could I still use the LeanMessageProvider instead of Kafka, or else where should I set the kafkaHosts.