Add shutdown() method to KafkaProducerApp
Clarify which code performs clean up at end of tests