reorganize code , move KafkaConsumer to its own module