Added a Common KafkaConsumer for all of the plugins