diff --git a/samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala b/samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala
index 949d923..05fd8bc 100644
--- a/samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala
+++ b/samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala
@@ -244,13 +244,6 @@
     info("CheckpointManager stopped.")
   }
 
-  override def finalize() {
-    super.finalize()
-    systemConsumer.stop()
-    systemAdmin.stop()
-    producerRef.get().stop()
-  }
-
   @VisibleForTesting
   def getSystemProducer(): SystemProducer = {
     systemFactory.getProducer(checkpointSystem, config, metricsRegistry, this.getClass.getSimpleName)