Modified Kafka Receiver . Creating Receiver for every Topic Partition. Modified Consumer.java to create Union of those Receivers