Made the KafkaReceiver to spawn consumer thread for every topic partition.
Made the PartitionManager to commit ZK offset every 2 Sec