Receiving from Kafka instead of from DMaap

Change-Id: If7175c235d596c567d84e567495fe830af75c522
26 files changed