XD-2098: Add KafkaMessageBus

Needs some more polish, but this is finally passing all tests
We need to support externalized kafka configurations options to set brokers, zk address etc., through servers.yml