diff --git perf/src/main/scala/kafka/perf/ConsumerPerformance.scala perf/src/main/scala/kafka/perf/ConsumerPerformance.scala
index 3158a22..40f8870 100644
--- perf/src/main/scala/kafka/perf/ConsumerPerformance.scala
+++ perf/src/main/scala/kafka/perf/ConsumerPerformance.scala
@@ -77,6 +77,7 @@ object ConsumerPerformance {
         config.consumerConfig.fetchMessageMaxBytes, totalMBRead, totalMBRead/elapsedSecs, totalMessagesRead.get,
         totalMessagesRead.get/elapsedSecs))
     }
+    consumerConnector.shutdown
     System.exit(0)
   }