Refactor towards making KafkaBrokerConnectionFactory the single entry point
Get rid of MessageProcessor in favour of MessageListener
Make dispatching/fanout a specific type of MessageListener