Changed method for closing consumer connections to kafka. Updated graph code.